You are viewing a plain text version of this content. The canonical link for it is here.

Posted to commits@kafka.apache.org by ab...@apache.org on 2022/02/18 08:41:39 UTC

[kafka] branch trunk updated (a4b1e50 -> 4c23e47)

This is an automated email from the ASF dual-hosted git repository.

ableegoldman pushed a change to branch trunk
in repository https://gitbox.apache.org/repos/asf/kafka.git.


    from a4b1e50  MINOR; Remove unused AdminZkClient in MetadataSupport (#11785)
     add 4c23e47  MINOR: move non-management methods from TaskManager to Task Executor (#11738)

No new revisions were added by this update.

Summary of changes:
 .../org/apache/kafka/streams/StreamsConfig.java    |  10 +-
 .../streams/internals/StreamsConfigUtils.java      |  69 ++++++
 .../processor/internals/ActiveTaskCreator.java     |  15 +-
 .../processor/internals/StandbyTaskCreator.java    |   3 +-
 .../streams/processor/internals/StreamThread.java  |  42 +---
 .../processor/internals/StreamsProducer.java       |  10 +-
 .../streams/processor/internals/TaskExecutor.java  | 267 +++++++++++++++++++++
 .../streams/processor/internals/TaskManager.java   | 233 ++----------------
 .../kafka/streams/processor/internals/Tasks.java   |   7 +-
 .../processor/internals/TopologyMetadata.java      |  10 +
 .../internals/namedtopology/TopologyConfig.java    |   4 +-
 .../org/apache/kafka/streams/KafkaStreamsTest.java |   9 +-
 .../processor/internals/StreamThreadTest.java      |   6 +-
 .../processor/internals/TaskManagerTest.java       |  20 +-
 .../internals/testutil/DummyStreamsConfig.java     |  12 +-
 .../StreamThreadStateStoreProviderTest.java        |   3 +-
 .../apache/kafka/streams/TopologyTestDriver.java   |  12 +-
 17 files changed, 433 insertions(+), 299 deletions(-)
 create mode 100644 streams/src/main/java/org/apache/kafka/streams/internals/StreamsConfigUtils.java
 create mode 100644 streams/src/main/java/org/apache/kafka/streams/processor/internals/TaskExecutor.java