You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@kafka.apache.org by mj...@apache.org on 2020/10/15 23:11:25 UTC
[kafka] branch trunk updated (a85802f -> e8ad80e)
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%)