This is an automated email from the ASF dual-hosted git repository.
guozhang pushed a change to branch trunk
in repository https://gitbox.apache.org/repos/asf/kafka.git
from 6d36db1c78f KAFKA-14765 and KAFKA-14776: Support for SCRAM at
bootstrap with integration tests (#13374)
add beb0be5fe45 KAFKA-14533: Do not interrupt state-updater thread during
shutdown (#13318)
No new revisions were added by this update.
Summary of changes:
.../org/apache/kafka/streams/KafkaStreams.java | 2 +-
.../streams/processor/internals/ClientUtils.java | 36 ++++++++++++++
.../processor/internals/DefaultStateUpdater.java | 57 +++++++++++++---------
.../internals/StreamsPartitionAssignor.java | 17 ++++---
.../streams/processor/internals/TaskManager.java | 2 +
.../SmokeTestDriverIntegrationTest.java | 3 +-
...ghAvailabilityStreamsPartitionAssignorTest.java | 39 +++------------
.../RackAwarenessStreamsPartitionAssignorTest.java | 35 +++----------
.../internals/StreamsPartitionAssignorTest.java | 19 +++-----
.../internals/assignment/AssignmentTestUtils.java | 19 +++-----
10 files changed, 112 insertions(+), 117 deletions(-)
