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 aed7ba9 MINOR: Remove unused isSticky assert out from tests only do constrainedAssign
(#8788)
add 5bcd7cc KAFKA-10102: update ProcessorTopology instead of rebuilding it (#8803)
No new revisions were added by this update.
Summary of changes:
.../streams/processor/internals/AbstractTask.java | 6 +-
.../internals/InternalTopologyBuilder.java | 15 ++---
.../processor/internals/ProcessorTopology.java | 72 +++++++++++++++++++---
.../streams/processor/internals/SourceNode.java | 24 +-------
.../streams/processor/internals/StreamTask.java | 16 ++---
.../kafka/streams/processor/internals/Task.java | 3 +-
.../streams/processor/internals/TaskManager.java | 2 +-
.../processor/internals/GlobalStateTaskTest.java | 2 -
.../processor/internals/PartitionGroupTest.java | 4 +-
.../processor/internals/ProcessorTopologyTest.java | 25 +++++++-
.../internals/RecordDeserializerTest.java | 4 +-
.../processor/internals/RecordQueueTest.java | 2 +-
.../processor/internals/SourceNodeTest.java | 7 +--
.../processor/internals/StreamTaskTest.java | 21 ++++++-
.../processor/internals/TaskManagerTest.java | 6 +-
.../java/org/apache/kafka/test/MockSourceNode.java | 6 +-
16 files changed, 139 insertions(+), 76 deletions(-)
|