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

Posted to commits@kafka.apache.org by bo...@apache.org on 2021/03/22 20:40:55 UTC

[kafka] branch trunk updated (7c45976 -> 80f373d)

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 7c45976  MINOR: bump documentation.html to 3.0
     add 80f373d  (Cherry-pick) KAFKA-9274: handle TimeoutException on task reset (#10000) (#10372)

No new revisions were added by this update.

Summary of changes:
 .../streams/processor/internals/StandbyTask.java   |  16 +--
 .../streams/processor/internals/StreamTask.java    |  36 ++++-
 .../streams/processor/internals/StreamThread.java  |   4 +-
 .../kafka/streams/processor/internals/Task.java    |   6 +-
 .../streams/processor/internals/TaskManager.java   |  22 +--
 .../processor/internals/StandbyTaskTest.java       |   2 +-
 .../processor/internals/StreamTaskTest.java        | 152 +++++++++++++++------
 .../processor/internals/StreamThreadTest.java      |   2 +-
 .../processor/internals/TaskManagerTest.java       | 149 +++++++++-----------
 .../apache/kafka/streams/TopologyTestDriver.java   |   2 +-
 10 files changed, 224 insertions(+), 167 deletions(-)