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 2020/04/15 20:13:52 UTC

[kafka] branch trunk updated (bd42734 -> 17f9879)

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 bd42734  MINOR: Serialize state change logs for handling LeaderAndIsr and StopReplica requests (#8493)
     add 17f9879  KAFKA-9832: extend Kafka Streams EOS system test (#8440)

No new revisions were added by this update.

Summary of changes:
 .../streams/processor/internals/StandbyTask.java   |   2 +-
 .../streams/processor/internals/StreamThread.java  |  12 +-
 .../streams/processor/internals/TaskManager.java   |  11 +-
 .../integration/StandbyTaskEOSIntegrationTest.java |  35 ++-
 .../processor/internals/StandbyTaskTest.java       |  31 ++-
 .../processor/internals/StreamThreadTest.java      |  83 ++++++--
 .../processor/internals/TaskManagerTest.java       |  95 ++++++++-
 .../apache/kafka/streams/tests/EosTestClient.java  |  94 +++-----
 .../apache/kafka/streams/tests/EosTestDriver.java  | 237 +++++++++++----------
 .../apache/kafka/streams/tests/SmokeTestUtil.java  |  63 +++---
 .../apache/kafka/streams/tests/StreamsEosTest.java |  10 +
 tests/kafkatest/services/streams.py                |  25 ++-
 tests/kafkatest/tests/streams/streams_eos_test.py  |  41 ++--
 13 files changed, 466 insertions(+), 273 deletions(-)