This is an automated email from the ASF dual-hosted git repository.
boyang pushed a change to branch trunk
in repository https://gitbox.apache.org/repos/asf/kafka.git.
from 728be21 MINOR: Update log level in SaslServerAuthenticator (#10270)
add 207bb08 KAFKA-12347: updating TaskMetadata (#10211)
No new revisions were added by this update.
Summary of changes:
.../org/apache/kafka/streams/KafkaStreams.java | 1 -
.../kafka/streams/processor/TaskMetadata.java | 31 +++++++++++-
.../streams/processor/internals/StandbyTask.java | 23 ++++++++-
.../streams/processor/internals/StreamTask.java | 44 ++++++++++++++---
.../streams/processor/internals/StreamThread.java | 22 +++++++--
.../kafka/streams/processor/internals/Task.java | 38 +++++++++++----
.../streams/processor/internals/TaskManager.java | 13 +++++
.../processor/internals/StreamTaskTest.java | 4 ++
.../processor/internals/StreamThreadTest.java | 56 ++--------------------
.../processor/internals/TaskManagerTest.java | 32 +++++++++++++
10 files changed, 188 insertions(+), 76 deletions(-)
