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/06/26 22:12:38 UTC
[kafka] branch trunk updated (fa2da1c -> 30df089)
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 fa2da1c MINOR: Rename SslTransportLayer.State."NOT_INITALIZED" enum value to "NOT_INITIALIZED"
add 30df089 KAFKA-10166: always write checkpoint before closing an (initialized) task (#8926)
No new revisions were added by this update.
Summary of changes:
.../streams/processor/internals/StandbyTask.java | 87 +++++++++++---
.../streams/processor/internals/StreamTask.java | 66 ++++++++---
.../streams/processor/internals/TaskManager.java | 105 ++++++++---------
.../processor/internals/StandbyTaskTest.java | 25 +++-
.../processor/internals/StreamTaskTest.java | 128 ++++++++++++++-------
.../processor/internals/TaskManagerTest.java | 23 ++--
.../apache/kafka/streams/TopologyTestDriver.java | 2 +
7 files changed, 281 insertions(+), 155 deletions(-)