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/03/22 20:50:33 UTC

[kafka] branch trunk updated (8aa1861 -> 1ad5f34)

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 8aa1861  KAFKA-9634: Add note about thread safety in the ConfigProvider interface (#8205)
     add 1ad5f34  KAFKA-9451: Enable producer per thread for Streams EOS (#8318)

No new revisions were added by this update.

Summary of changes:
 .../org/apache/kafka/streams/StreamsConfig.java    | 109 +++--
 .../processor/internals/ActiveTaskCreator.java     |  48 +-
 .../processor/internals/StandbyTaskCreator.java    |   4 +-
 .../streams/processor/internals/StreamTask.java    |   4 +-
 .../streams/processor/internals/StreamThread.java  |  40 +-
 .../processor/internals/StreamsProducer.java       |  15 +-
 .../streams/processor/internals/TaskManager.java   | 104 +++--
 .../org/apache/kafka/streams/KafkaStreamsTest.java |   1 +
 .../apache/kafka/streams/StreamsConfigTest.java    | 144 +++++-
 .../processor/internals/ActiveTaskCreatorTest.java | 515 +++++++++++++++------
 .../processor/internals/RecordCollectorTest.java   |  10 +-
 .../processor/internals/StreamsProducerTest.java   | 113 +++--
 .../processor/internals/TaskManagerTest.java       | 275 ++++++++++-
 .../streams/state/KeyValueStoreTestDriver.java     |   2 +-
 .../StreamThreadStateStoreProviderTest.java        |   1 -
 .../apache/kafka/streams/TopologyTestDriver.java   |   4 +-
 .../processor/internals/TestDriverProducer.java    |  10 +-
 17 files changed, 1060 insertions(+), 339 deletions(-)