This is an automated email from the ASF dual-hosted git repository.
kharekartik pushed a change to branch master
in repository https://gitbox.apache.org/repos/asf/pinot.git
from 2d22c6d12c Bump up frontend-maven-plugin (#8461)
add d7be2ef412 Fetch Pulsar offsets from Consumer interface instead of
Reader (#8017)
No new revisions were added by this update.
Summary of changes:
.../pinot/plugin/stream/pulsar/PulsarConfig.java | 21 ++--
.../plugin/stream/pulsar/PulsarMessageBatch.java | 26 ++++-
.../PulsarPartitionLevelConnectionHandler.java | 2 +-
.../pulsar/PulsarStreamMetadataProvider.java | 59 ++++++++---
.../pinot/plugin/stream/pulsar/PulsarUtils.java | 54 ++++++++++
.../plugin/stream/pulsar/PulsarConsumerTest.java | 117 +++++++++++++++++++--
6 files changed, 237 insertions(+), 42 deletions(-)
create mode 100644
pinot-plugins/pinot-stream-ingestion/pinot-pulsar/src/main/java/org/apache/pinot/plugin/stream/pulsar/PulsarUtils.java
---------------------------------------------------------------------
To unsubscribe, e-mail: [email protected]
For additional commands, e-mail: [email protected]
