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 ddb6959 KAFKA-12980; Return empty record batch from Consumer::poll
when position advances due to aborted transactions (#11046)
add e20f102 KAFKA-12648: extend IQ APIs to work with named topologies
(#11562)
No new revisions were added by this update.
Summary of changes:
.../org/apache/kafka/streams/KafkaStreams.java | 22 ++--
.../apache/kafka/streams/StoreQueryParameters.java | 2 +-
.../processor/internals/StreamsMetadataState.java | 146 ++++++++++++++++++++-
.../KafkaStreamsNamedTopologyWrapper.java | 68 ++++++++++
.../NamedTopologyStoreQueryParameters.java | 74 +++++++++++
.../NamedTopologyStreamsMetadataImpl.java | 72 ++++++++++
.../internals/StreamThreadStateStoreProvider.java | 15 ++-
.../integration/NamedTopologyIntegrationTest.java | 17 ++-
8 files changed, 397 insertions(+), 19 deletions(-)
create mode 100644
streams/src/main/java/org/apache/kafka/streams/processor/internals/namedtopology/NamedTopologyStoreQueryParameters.java
create mode 100644
streams/src/main/java/org/apache/kafka/streams/processor/internals/namedtopology/NamedTopologyStreamsMetadataImpl.java
