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 (ad3b843 -> 74f8ae1)
Date Tue, 24 Sep 2019 22:33:44 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 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


Mime
View raw message