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 9064026 KAFKA-8147: Add changelog topic configuration to KTable
suppress (#8029)
add a28447a MINOR: don't assign standby tasks with no logged state (#8147)
No new revisions were added by this update.
Summary of changes:
.../org/apache/kafka/streams/KafkaStreams.java | 2 +-
.../internals/InternalTopologyBuilder.java | 35 ++++--
.../processor/internals/ProcessorTopology.java | 17 ++-
.../streams/processor/internals/StreamThread.java | 6 +-
.../internals/StreamsPartitionAssignor.java | 37 +++---
.../internals/assignment/StickyTaskAssignor.java | 22 ++--
.../apache/kafka/streams/StreamsBuilderTest.java | 80 ++++++-------
.../internals/InternalStreamsBuilderTest.java | 36 ++----
.../streams/kstream/internals/KStreamImplTest.java | 10 +-
.../internals/InternalTopologyBuilderTest.java | 18 +--
.../processor/internals/ProcessorTopologyTest.java | 16 +--
.../processor/internals/StreamThreadTest.java | 2 +-
.../internals/StreamsPartitionAssignorTest.java | 125 +++++++++++++++++----
.../assignment/StickyTaskAssignorTest.java | 1 +
.../StreamThreadStateStoreProviderTest.java | 2 +-
.../apache/kafka/streams/TopologyTestDriver.java | 2 +-
16 files changed, 263 insertions(+), 148 deletions(-)
