This is an automated email from the ASF dual-hosted git repository.
xiangfu pushed a change to branch master
in repository https://gitbox.apache.org/repos/asf/pinot.git
from 2a9cd82b98 Make segment completion FSM pluggable (#14088)
add 306be4214c [FEATURE] Add getTopics API to StreamMetadataProvider for
Topic Enumeration in Streaming Connectors (#14654)
No new revisions were added by this update.
Summary of changes:
.../kafka20/KafkaStreamMetadataProvider.java | 26 ++++++++++++++++++++
.../kafka30/KafkaStreamMetadataProvider.java | 25 +++++++++++++++++++
.../kafka30/KafkaPartitionLevelConsumerTest.java | 28 ++++++++++++++++++++++
.../pinot/spi/stream/StreamMetadataProvider.java | 16 +++++++++++++
4 files changed, 95 insertions(+)
---------------------------------------------------------------------
To unsubscribe, e-mail: [email protected]
For additional commands, e-mail: [email protected]
