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

Posted to commits@kafka.apache.org by vv...@apache.org on 2020/03/24 21:29:19 UTC

[kafka] branch trunk updated (4c96b7d -> 8012f47)

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

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


    from 4c96b7d  KAFKA-9749; Transaction coordinator should treat KAFKA_STORAGE_ERROR as retriable (#8336)
     add 8012f47  MINOR: move some client methods to new ClientUtils (#8328)

No new revisions were added by this update.

Summary of changes:
 .../org/apache/kafka/streams/KafkaStreams.java     |  34 +------
 .../processor/internals/ActiveTaskCreator.java     |  35 ++-----
 .../streams/processor/internals/ClientUtils.java   | 111 +++++++++++++++++++++
 .../streams/processor/internals/StreamThread.java  |  31 ++----
 .../internals/StreamsPartitionAssignor.java        |   2 +-
 .../org/apache/kafka/streams/KafkaStreamsTest.java |  67 -------------
 .../processor/internals/ClientUtilsTest.java       |  96 ++++++++++++++++++
 .../processor/internals/StreamThreadTest.java      |   2 +-
 8 files changed, 229 insertions(+), 149 deletions(-)
 create mode 100644 streams/src/main/java/org/apache/kafka/streams/processor/internals/ClientUtils.java
 create mode 100644 streams/src/test/java/org/apache/kafka/streams/processor/internals/ClientUtilsTest.java