You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@kafka.apache.org by ab...@apache.org on 2021/08/06 07:20:12 UTC
[kafka] branch trunk updated (04023d4 -> 6854eb8)
This is an automated email from the ASF dual-hosted git repository.
ableegoldman pushed a change to branch trunk
in repository https://gitbox.apache.org/repos/asf/kafka.git.
from 04023d4 KAFKA-13132; Upgrading to topic IDs in LISR requests has gaps introduced in 3.0 (part 2) (#11171)
add 6854eb8 KAFKA-12648: Pt. 3 - addNamedTopology API (#10788)
No new revisions were added by this update.
Summary of changes:
checkstyle/suppressions.xml | 2 +-
.../java/org/apache/kafka/common/utils/Utils.java | 5 +
.../org/apache/kafka/streams/KafkaStreams.java | 23 +-
.../streams/internals/metrics/ClientMetrics.java | 4 +-
.../processor/internals/ActiveTaskCreator.java | 28 +++
.../internals/InternalTopologyBuilder.java | 20 +-
.../processor/internals/StandbyTaskCreator.java | 28 ++-
.../processor/internals/StateDirectory.java | 24 +-
.../streams/processor/internals/StreamThread.java | 33 ++-
.../internals/StreamsPartitionAssignor.java | 20 +-
.../kafka/streams/processor/internals/Task.java | 1 -
.../streams/processor/internals/TaskManager.java | 143 +++++++++---
.../kafka/streams/processor/internals/Tasks.java | 17 ++
.../processor/internals/TopologyMetadata.java | 214 +++++++++++++-----
.../internals/assignment/ClientState.java | 18 ++
.../KafkaStreamsNamedTopologyWrapper.java | 87 ++++++--
.../internals/namedtopology/NamedTopology.java | 2 +-
.../org/apache/kafka/streams/KafkaStreamsTest.java | 2 +-
.../integration/NamedTopologyIntegrationTest.java | 246 +++++++++++++++++----
.../internals/metrics/ClientMetricsTest.java | 7 +-
...ghAvailabilityStreamsPartitionAssignorTest.java | 1 +
.../processor/internals/NamedTopologyTest.java | 19 +-
.../processor/internals/StateDirectoryTest.java | 25 +++
.../processor/internals/StreamThreadTest.java | 11 +-
.../internals/StreamsPartitionAssignorTest.java | 1 +
.../processor/internals/TaskManagerTest.java | 12 +-
.../internals/assignment/ClientStateTest.java | 19 ++
.../apache/kafka/streams/TopologyTestDriver.java | 1 -
28 files changed, 794 insertions(+), 219 deletions(-)