kafka-commits mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From guozh...@apache.org
Subject [kafka] branch trunk updated (9064026 -> a28447a)
Date Tue, 25 Feb 2020 23:28:50 GMT
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(-)


Mime
View raw message