This is an automated email from the ASF dual-hosted git repository.
mjsax pushed a change to branch trunk
in repository https://gitbox.apache.org/repos/asf/kafka.git.
from a85802f KAFKA-10559: Not letting TimeoutException shutdown the app
during internal topic validation (#9432)
add e8ad80e MINOR: remove explicit passing of AdminClient into
StreamsPartitionAssignor (#9384)
No new revisions were added by this update.
Summary of changes:
checkstyle/suppressions.xml | 2 +-
.../org/apache/kafka/streams/StreamsConfig.java | 7 +-
.../streams/processor/internals/StreamThread.java | 25 ++---
.../internals/StreamsPartitionAssignor.java | 27 +++--
.../streams/processor/internals/TaskManager.java | 12 +-
.../assignment/AssignorConfiguration.java | 123 ++-------------------
.../internals/assignment/ReferenceContainer.java} | 31 +++---
.../integration/EosBetaUpgradeIntegrationTest.java | 2 +-
...ghAvailabilityStreamsPartitionAssignorTest.java | 24 ++--
.../processor/internals/StreamThreadTest.java | 5 +-
.../internals/StreamsAssignmentScaleTest.java | 55 +++++----
.../internals/StreamsPartitionAssignorTest.java | 102 +++++------------
.../kafka/streams/tests/StreamsUpgradeTest.java | 2 +-
13 files changed, 132 insertions(+), 285 deletions(-)
copy
streams/src/{test/java/org/apache/kafka/streams/processor/internals/assignment/AssignorConfigurationTest.java
=>
main/java/org/apache/kafka/streams/processor/internals/assignment/ReferenceContainer.java}
(53%)
