This is an automated email from the ASF dual-hosted git repository.
ableegoldman pushed a change to branch trunk
in repository https://gitbox.apache.org/repos/asf/kafka.git
from dd755b7ea95 KAFKA-8206: KIP-899: Allow client to rebootstrap (#13277)
add 16e2b68b734 KAFKA-15045: (KIP-924 pt. 23) More TaskAssignmentUtils
tests (#16292)
No new revisions were added by this update.
Summary of changes:
.../processor/assignment/AssignmentConfigs.java | 24 +--
.../assignment/KafkaStreamsAssignment.java | 16 ++
.../streams/processor/assignment/ProcessId.java | 8 +
.../processor/assignment/TaskAssignmentUtils.java | 8 +-
.../assignment/assignors/StickyTaskAssignor.java | 23 +-
.../internals/StreamsPartitionAssignor.java | 3 +-
.../internals/StreamsPartitionAssignorTest.java | 126 -----------
.../processor/internals/TaskManagerTest.java | 3 +-
.../assignment/KafkaStreamsAssignmentTest.java | 49 +++++
.../assignment/KafkaStreamsStateTest.java | 5 +-
.../assignment/TaskAssignmentUtilsTest.java | 233 ++++++++++++++++++++-
11 files changed, 333 insertions(+), 165 deletions(-)
create mode 100644
streams/src/test/java/org/apache/kafka/streams/processor/internals/assignment/KafkaStreamsAssignmentTest.java
