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 14c2449 KAFKA-13491: IQv2 framework (#11557)
add 965ec40 KAFKA-12648: Make changing the named topologies have a
blocking option (#11479)
No new revisions were added by this update.
Summary of changes:
.../org/apache/kafka/streams/KafkaStreams.java | 2 +-
.../streams/processor/internals/StreamThread.java | 15 +-
.../processor/internals/TopologyMetadata.java | 79 +++++++++-
.../namedtopology/AddNamedTopologyResult.java | 25 ++-
.../KafkaStreamsNamedTopologyWrapper.java | 103 ++++++++++++-
.../namedtopology/RemoveNamedTopologyResult.java | 85 +++++++++++
.../integration/NamedTopologyIntegrationTest.java | 169 ++++++++++++++++++---
7 files changed, 426 insertions(+), 52 deletions(-)
copy
clients/src/main/java/org/apache/kafka/clients/admin/UnregisterBrokerResult.java
=>
streams/src/main/java/org/apache/kafka/streams/processor/internals/namedtopology/AddNamedTopologyResult.java
(58%)
create mode 100644
streams/src/main/java/org/apache/kafka/streams/processor/internals/namedtopology/RemoveNamedTopologyResult.java
