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 000eb47084 Bump com.gradle:develocity-maven-extension from 1.22.2 to
1.23 (#14846)
add 085c995734 [kinesis] Added getTopics() implementation for kinesis
(#14854)
No new revisions were added by this update.
Summary of changes:
.../stream/kinesis/KinesisConnectionHandler.java | 36 +++++
.../kinesis/KinesisStreamMetadataProvider.java | 21 +++
.../KinesisConnectionHandlerIntegrationTest.java | 147 +++++++++++++++++++++
3 files changed, 204 insertions(+)
create mode 100644
pinot-plugins/pinot-stream-ingestion/pinot-kinesis/src/test/java/org/apache/pinot/plugin/stream/kinesis/KinesisConnectionHandlerIntegrationTest.java
---------------------------------------------------------------------
To unsubscribe, e-mail: [email protected]
For additional commands, e-mail: [email protected]
