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