kafka-commits mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From guozh...@apache.org
Subject [kafka] branch trunk updated (fa2da1c -> 30df089)
Date Fri, 26 Jun 2020 22:12:38 GMT
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(-)


Mime
View raw message