You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@kafka.apache.org by gu...@apache.org on 2020/03/27 05:54:52 UTC
[kafka] branch trunk updated (c59835c -> 9d9b59f)
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(-)