kafka-commits mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From mj...@apache.org
Subject [kafka] branch trunk updated (aed7ba9 -> 5bcd7cc)
Date Mon, 08 Jun 2020 22:55:53 GMT
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(-)


Mime
View raw message