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

Posted to commits@kafka.apache.org by ab...@apache.org on 2022/03/01 21:05:08 UTC

[kafka] branch trunk updated (67e99a4 -> 6eb57f6)

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

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


    from 67e99a4  MINOR: Ensure LocalLog.flush is thread safe to recoveryPoint changes (#11814)
     add 6eb57f6  KAFKA-12738: address minor followup and consolidate integration tests of PR #11787 (#11812)

No new revisions were added by this update.

Summary of changes:
 .../streams/processor/internals/StreamThread.java  |   1 +
 .../processor/internals/TaskExecutionMetadata.java |   8 +-
 .../integration/EmitOnChangeIntegrationTest.java   | 175 ---------------------
 .../integration/ErrorHandlingIntegrationTest.java  | 161 -------------------
 .../integration/NamedTopologyIntegrationTest.java  |  70 +++++++++
 ...amsUncaughtExceptionHandlerIntegrationTest.java | 132 +++++++++++++---
 6 files changed, 184 insertions(+), 363 deletions(-)
 delete mode 100644 streams/src/test/java/org/apache/kafka/streams/integration/EmitOnChangeIntegrationTest.java
 delete mode 100644 streams/src/test/java/org/apache/kafka/streams/integration/ErrorHandlingIntegrationTest.java