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 03e6aa43988 KAFKA-20266: Add tracking of assignment timestamps (#21652)
add 66cc6b6297e KAFKA-19939 Extend ProcessingExceptionHandler to
GlobalKTable processors (#21535)
No new revisions were added by this update.
Summary of changes:
docs/streams/developer-guide/config-streams.md | 29 +++-
docs/streams/upgrade-guide.md | 2 +
.../integration/GlobalKTableIntegrationTest.java | 150 ++++++++++++++++++++-
.../org/apache/kafka/streams/StreamsConfig.java | 15 +++
.../internals/GlobalStateManagerImpl.java | 118 +++++++++++++---
.../processor/internals/GlobalStateUpdateTask.java | 6 +-
.../processor/internals/GlobalStreamThread.java | 5 +-
.../internals/InternalTopologyBuilder.java | 11 +-
.../streams/processor/internals/ProcessorNode.java | 34 ++---
.../internals/GlobalStateManagerImplTest.java | 1 +
.../processor/internals/GlobalStateTaskTest.java | 121 +++++++++++++++++
.../apache/kafka/streams/TopologyTestDriver.java | 7 +
12 files changed, 457 insertions(+), 42 deletions(-)
