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 bbfecae MINOR: Document endpoints for connector topic tracking
(KIP-558)
add 97d107a KAFKA-9441: Add internal TransactionManager (#8105)
No new revisions were added by this update.
Summary of changes:
.../kafka/clients/producer/MockProducer.java | 103 ++-
.../kafka/clients/producer/MockProducerTest.java | 8 +
.../streams/errors/TaskMigratedException.java | 2 +-
.../processor/internals/RecordCollectorImpl.java | 319 +++------
.../processor/internals/StoreChangelogReader.java | 16 +-
.../streams/processor/internals/StreamTask.java | 15 +-
.../streams/processor/internals/StreamThread.java | 132 ++--
.../processor/internals/StreamsProducer.java | 227 ++++++
.../streams/processor/internals/TaskManager.java | 40 +-
.../org/apache/kafka/streams/KafkaStreamsTest.java | 8 +-
.../internals/ProcessorStateManagerTest.java | 6 +-
.../processor/internals/RecordCollectorTest.java | 797 +++++++--------------
.../processor/internals/StreamThreadTest.java | 61 +-
.../processor/internals/StreamsProducerTest.java | 638 +++++++++++++++++
.../processor/internals/TaskManagerTest.java | 3 +-
.../streams/state/KeyValueStoreTestDriver.java | 13 +-
.../StreamThreadStateStoreProviderTest.java | 23 +-
.../org/apache/kafka/test/MockClientSupplier.java | 2 +-
.../org/apache/kafka/test/MockKeyValueStore.java | 11 +-
.../kafka/test/MockKeyValueStoreBuilder.java | 4 +-
.../apache/kafka/streams/TopologyTestDriver.java | 143 ++--
21 files changed, 1615 insertions(+), 956 deletions(-)
create mode 100644
streams/src/main/java/org/apache/kafka/streams/processor/internals/StreamsProducer.java
create mode 100644
streams/src/test/java/org/apache/kafka/streams/processor/internals/StreamsProducerTest.java
