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 ad3b843 KAFKA-8580: Compute RocksDB metrics (#7263)
add 74f8ae1 KAFKA-8179: do not suspend standby tasks during rebalance
(#7321)
No new revisions were added by this update.
Summary of changes:
.../consumer/ConsumerRebalanceListener.java | 16 +-
.../consumer/internals/ConsumerCoordinator.java | 74 +++--
.../org/apache/kafka/streams/KafkaStreams.java | 15 +-
.../org/apache/kafka/streams/StreamsConfig.java | 43 ++-
.../processor/internals/AssignedStandbyTasks.java | 42 +++
.../processor/internals/AssignedStreamsTasks.java | 293 ++++++++++++++++++--
.../streams/processor/internals/AssignedTasks.java | 137 +---------
.../processor/internals/ChangelogReader.java | 15 +-
.../processor/internals/StoreChangelogReader.java | 24 +-
.../streams/processor/internals/StreamThread.java | 214 +++++----------
.../internals/StreamsPartitionAssignor.java | 39 ++-
.../internals/StreamsRebalanceListener.java | 169 ++++++++++++
.../streams/processor/internals/TaskManager.java | 297 ++++++++++++++-------
.../assignment/AssignorConfiguration.java | 24 ++
.../integration/RegexSourceIntegrationTest.java | 4 +-
.../internals/AssignedStreamsTasksTest.java | 36 ++-
.../processor/internals/MockChangelogReader.java | 10 +-
.../processor/internals/StreamThreadTest.java | 66 +++--
.../internals/StreamsPartitionAssignorTest.java | 2 +-
.../processor/internals/TaskManagerTest.java | 114 ++++----
.../kafka/streams/tests/StreamsUpgradeTest.java | 7 +-
21 files changed, 1085 insertions(+), 556 deletions(-)
create mode 100644
streams/src/main/java/org/apache/kafka/streams/processor/internals/StreamsRebalanceListener.java
