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 d4eb406 KAFKA-9807; Protect LSO reads from concurrent high-watermark
updates (#8418)
add ab5e4f5 MINOR: Refactor StreamsProducer (#8380)
No new revisions were added by this update.
Summary of changes:
.../org/apache/kafka/streams/StreamsConfig.java | 2 +-
.../processor/internals/ActiveTaskCreator.java | 52 +-
.../streams/processor/internals/ClientUtils.java | 21 +-
.../streams/processor/internals/StreamThread.java | 30 +-
.../processor/internals/StreamsProducer.java | 87 ++-
.../org/apache/kafka/streams/KafkaStreamsTest.java | 5 +-
.../processor/internals/ActiveTaskCreatorTest.java | 159 +-----
.../processor/internals/RecordCollectorTest.java | 152 ++++--
.../processor/internals/StreamThreadTest.java | 4 +-
.../processor/internals/StreamsProducerTest.java | 592 +++++++++++++++------
.../streams/state/KeyValueStoreTestDriver.java | 36 +-
.../StreamThreadStateStoreProviderTest.java | 16 +-
.../org/apache/kafka/test/MockClientSupplier.java | 5 +-
.../apache/kafka/streams/TopologyTestDriver.java | 32 +-
.../processor/internals/TestDriverProducer.java | 11 +-
15 files changed, 719 insertions(+), 485 deletions(-)
