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

Posted to commits@kafka.apache.org by mj...@apache.org on 2021/02/19 21:37:33 UTC

[kafka] branch trunk updated (1c31176 -> b35ca43)

This is an automated email from the ASF dual-hosted git repository.

mjsax pushed a change to branch trunk
in repository https://gitbox.apache.org/repos/asf/kafka.git.


    from 1c31176  KAFKA-12343: Handle exceptions better in TopicAdmin, including UnsupportedVersionException (#10158)
     add b35ca43  KAFKA-9274: Throw TaskCorruptedException instead of TimeoutException when TX commit times out (#10072)

No new revisions were added by this update.

Summary of changes:
 docs/streams/upgrade-guide.html                    |   9 ++
 .../streams/errors/TaskCorruptedException.java     |  22 ++--
 .../streams/errors/TaskTimeoutExceptions.java      |  58 -----------
 .../processor/internals/ProcessorStateManager.java |  10 +-
 .../processor/internals/RecordCollectorImpl.java   |  22 ++--
 .../processor/internals/StoreChangelogReader.java  |   9 +-
 .../streams/processor/internals/StreamTask.java    |   2 +-
 .../streams/processor/internals/StreamThread.java  |   4 +-
 .../streams/processor/internals/TaskManager.java   | 114 ++++++++++++---------
 .../internals/ProcessorStateManagerTest.java       |   4 +-
 .../processor/internals/StreamThreadTest.java      |  20 ++--
 .../processor/internals/TaskManagerTest.java       |  52 +++++-----
 12 files changed, 141 insertions(+), 185 deletions(-)
 delete mode 100644 streams/src/main/java/org/apache/kafka/streams/errors/TaskTimeoutExceptions.java