You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@kafka.apache.org by ca...@apache.org on 2022/03/16 17:11:18 UTC
[kafka] branch trunk updated (5c1dd49 -> b68463c)
This is an automated email from the ASF dual-hosted git repository.
cadonna pushed a change to branch trunk
in repository https://gitbox.apache.org/repos/asf/kafka.git.
from 5c1dd49 Don't generate Uuid with a leading "-" (#11901)
add b68463c KAFKA-6718 / Add rack awareness configurations to StreamsConfig (#11837)
No new revisions were added by this update.
Summary of changes:
.../org/apache/kafka/common/config/ConfigDef.java | 21 +
.../apache/kafka/common/config/ConfigDefTest.java | 42 +-
.../org/apache/kafka/streams/StreamsConfig.java | 92 +++++
.../streams/processor/internals/StreamThread.java | 1 +
.../internals/StreamsPartitionAssignor.java | 18 +-
.../assignment/AssignorConfiguration.java | 6 +-
.../internals/assignment/ClientState.java | 8 +-
.../ClientTagAwareStandbyTaskAssignor.java | 56 ++-
.../assignment/DefaultStandbyTaskAssignor.java | 18 +-
.../assignment/HighAvailabilityTaskAssignor.java | 11 +-
.../internals/assignment/ReferenceContainer.java | 2 +
.../assignment/StandbyTaskAssignmentUtils.java | 19 +-
...signor.java => StandbyTaskAssignorFactory.java} | 14 +-
.../apache/kafka/streams/StreamsConfigTest.java | 105 +++++
.../integration/RackAwarenessIntegrationTest.java | 436 +++++++++++++++++++++
.../internals/StreamsPartitionAssignorTest.java | 21 +-
.../internals/assignment/AssignmentTestUtils.java | 9 +
.../ClientTagAwareStandbyTaskAssignorTest.java | 42 +-
.../HighAvailabilityTaskAssignorTest.java | 25 --
.../assignment/StandbyTaskAssignmentUtilsTest.java | 54 +--
.../assignment/StandbyTaskAssignorFactoryTest.java | 52 +++
21 files changed, 927 insertions(+), 125 deletions(-)
copy streams/src/main/java/org/apache/kafka/streams/processor/internals/assignment/{StandbyTaskAssignor.java => StandbyTaskAssignorFactory.java} (69%)
create mode 100644 streams/src/test/java/org/apache/kafka/streams/integration/RackAwarenessIntegrationTest.java
create mode 100644 streams/src/test/java/org/apache/kafka/streams/processor/internals/assignment/StandbyTaskAssignorFactoryTest.java