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 c59835c KAFKA-8470: State change logs should not be in TRACE level
(#8320)
add 9d9b59f KAFKA-9756: Process more than one record of one task at a
time (#8358)
No new revisions were added by this update.
Summary of changes:
.../streams/processor/internals/StreamTask.java | 14 +-
.../streams/processor/internals/StreamThread.java | 154 +++++++++++----------
.../streams/processor/internals/TaskManager.java | 11 +-
.../processor/internals/metrics/ThreadMetrics.java | 75 ++++++++++
.../processor/internals/StreamThreadTest.java | 41 ++++--
.../processor/internals/TaskManagerTest.java | 60 +++++---
6 files changed, 241 insertions(+), 114 deletions(-)
