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/01 20:20:57 UTC
[kafka] branch trunk updated (fee5f0e -> cc59150)
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 fee5f0e MINOR: Rename TopicCommandTest (#8398)
add cc59150 KAFKA-9748: extend EosIntegrationTest for EOS-beta (#8331)
No new revisions were added by this update.
Summary of changes:
.../processor/internals/ActiveTaskCreator.java | 39 ++-
.../streams/processor/internals/StreamThread.java | 2 +-
.../processor/internals/StreamsProducer.java | 44 ++-
.../streams/processor/internals/TaskManager.java | 10 +-
.../streams/integration/EosIntegrationTest.java | 58 ++--
.../processor/internals/ActiveTaskCreatorTest.java | 140 +++++++-
.../processor/internals/RecordCollectorTest.java | 18 +-
.../processor/internals/StreamsProducerTest.java | 370 ++++++++++++++-------
.../processor/internals/TaskManagerTest.java | 34 +-
.../streams/state/KeyValueStoreTestDriver.java | 3 +-
.../StreamThreadStateStoreProviderTest.java | 11 +-
.../apache/kafka/streams/TopologyTestDriver.java | 23 +-
.../processor/internals/TestDriverProducer.java | 4 +-
13 files changed, 561 insertions(+), 195 deletions(-)