This is an automated email from the ASF dual-hosted git repository.
nehapawar pushed a change to branch master
in repository https://gitbox.apache.org/repos/asf/pinot.git
from fb66e0c19f Handle concurrent updates in Pulsar test (#8797)
add 2124a16502 Make row metadata available in Kafka 2.0 record ingestion
(#8774)
No new revisions were added by this update.
Summary of changes:
.../plugin/stream/kafka20/KafkaMessageBatch.java | 11 ++-
.../KafkaPartitionLevelConnectionHandler.java | 2 +
.../kafka20/KafkaPartitionLevelConsumer.java | 6 +-
.../kafka20/KafkaPartitionLevelStreamConfig.java | 53 +++++++------
.../kafka20/MessageAndOffsetAndMetadata.java} | 26 +++++--
.../stream/kafka20/RowMetadataExtractor.java} | 17 +++--
.../kafka20/KafkaPartitionLevelConsumerTest.java | 88 +++++++++++++++++++---
.../KafkaPartitionLevelStreamConfigTest.java | 45 ++++++++---
.../pinot/spi/stream/StreamConfigProperties.java | 1 +
9 files changed, 185 insertions(+), 64 deletions(-)
copy
pinot-plugins/pinot-stream-ingestion/pinot-kafka-2.0/src/{test/java/org/apache/pinot/plugin/stream/kafka20/KafkaPartitionLevelConsumerBackwardCompatibilityTest.java
=>
main/java/org/apache/pinot/plugin/stream/kafka20/MessageAndOffsetAndMetadata.java}
(57%)
copy
pinot-plugins/pinot-stream-ingestion/pinot-kafka-2.0/src/{test/java/org/apache/pinot/plugin/stream/kafka20/KafkaPartitionLevelConsumerBackwardCompatibilityTest.java
=> main/java/org/apache/pinot/plugin/stream/kafka20/RowMetadataExtractor.java}
(65%)
---------------------------------------------------------------------
To unsubscribe, e-mail: [email protected]
For additional commands, e-mail: [email protected]
