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/01/26 19:44:50 UTC

[kafka] branch trunk updated (6c8033a -> 647c609)

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 6c8033a  MINOR: Add docs for StreamJoined changes (#9951)
     add 647c609  KAFKA-10555: Improve client state machine (#9720)

No new revisions were added by this update.

Summary of changes:
 .../org/apache/kafka/streams/KafkaStreams.java     | 78 +++++++++---------
 .../streams/processor/internals/StreamThread.java  | 15 +++-
 .../org/apache/kafka/streams/KafkaStreamsTest.java | 93 ++++++----------------
 .../EOSUncleanShutdownIntegrationTest.java         |  2 -
 .../integration/EosBetaUpgradeIntegrationTest.java | 40 ++++++----
 .../integration/StandbyTaskEOSIntegrationTest.java |  9 +--
 ...amsUncaughtExceptionHandlerIntegrationTest.java |  8 +-
 .../integration/SuppressionIntegrationTest.java    |  2 +-
 ...HandlingSourceTopicDeletionIntegrationTest.java | 12 ++-
 9 files changed, 115 insertions(+), 144 deletions(-)