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 4a26fba3c3 minor: changes as a follow up PR (#14000)
add 3df697cb48 Kafka3 support (#13891)
No new revisions were added by this update.
Summary of changes:
.../tests/LLCRealtimeClusterIntegrationTest.java | 2 +-
...> LLCRealtimeKafka3ClusterIntegrationTest.java} | 33 +++++++++----------
.../pinot-stream-ingestion/pinot-kafka-2.0/pom.xml | 20 +++---------
.../stream/kafka20/KafkaConsumerFactory.java | 1 +
.../KafkaPartitionLevelConnectionHandler.java | 2 ++
.../kafka20/KafkaPartitionLevelConsumer.java | 2 ++
.../kafka20/KafkaStreamMetadataProvider.java | 1 +
.../KafkaPartitionLevelStreamConfigTest.java | 2 ++
.../stream/kafka20/utils/MiniKafkaCluster.java | 1 +
.../{pinot-kafka-2.0 => pinot-kafka-3.0}/pom.xml | 37 +++++++++++-----------
.../stream/kafka30}/KafkaConsumerFactory.java | 3 +-
.../KafkaPartitionLevelConnectionHandler.java | 6 ++--
.../kafka30}/KafkaPartitionLevelConsumer.java | 4 ++-
.../kafka30}/KafkaStreamMetadataProvider.java | 3 +-
...tionLevelConsumerBackwardCompatibilityTest.java | 6 ++--
.../kafka30}/KafkaPartitionLevelConsumerTest.java | 5 ++-
.../KafkaPartitionLevelStreamConfigTest.java | 20 ++----------
.../stream/kafka30}/utils/MiniKafkaCluster.java | 26 +++++++++++----
.../pinot-kafka-3.0}/src/test/resources/log4j2.xml | 0
.../pinot-kafka-base/pom.xml | 19 +++++++++++
.../kafka}/KafkaConfigBackwardCompatibleUtils.java | 2 +-
.../stream/kafka}/KafkaConsumerPartitionLag.java | 2 +-
.../plugin/stream/kafka}/KafkaMessageBatch.java | 2 +-
.../kafka}/KafkaPartitionLevelStreamConfig.java | 3 +-
.../pinot/plugin/stream/kafka}/KafkaSSLUtils.java | 2 +-
.../stream/kafka}/KafkaStreamMessageMetadata.java | 2 +-
.../plugin/stream/kafka}/KafkaSSLUtilsTest.java | 2 +-
.../stream/kafka}/utils/EmbeddedZooKeeper.java | 4 +--
pinot-plugins/pinot-stream-ingestion/pom.xml | 1 +
.../org/apache/pinot/spi/plugin/PluginManager.java | 2 ++
pinot-tools/pom.xml | 5 +++
pom.xml | 11 +++++++
32 files changed, 135 insertions(+), 96 deletions(-)
copy
pinot-integration-tests/src/test/java/org/apache/pinot/integration/tests/{LLCRealtimeClusterIntegrationTest.java
=> LLCRealtimeKafka3ClusterIntegrationTest.java} (94%)
copy pinot-plugins/pinot-stream-ingestion/{pinot-kafka-2.0 =>
pinot-kafka-3.0}/pom.xml (76%)
copy
pinot-plugins/pinot-stream-ingestion/{pinot-kafka-2.0/src/main/java/org/apache/pinot/plugin/stream/kafka20
=>
pinot-kafka-3.0/src/main/java/org/apache/pinot/plugin/stream/kafka30}/KafkaConsumerFactory.java
(93%)
copy
pinot-plugins/pinot-stream-ingestion/{pinot-kafka-2.0/src/main/java/org/apache/pinot/plugin/stream/kafka20
=>
pinot-kafka-3.0/src/main/java/org/apache/pinot/plugin/stream/kafka30}/KafkaPartitionLevelConnectionHandler.java
(94%)
copy
pinot-plugins/pinot-stream-ingestion/{pinot-kafka-2.0/src/main/java/org/apache/pinot/plugin/stream/kafka20
=>
pinot-kafka-3.0/src/main/java/org/apache/pinot/plugin/stream/kafka30}/KafkaPartitionLevelConsumer.java
(96%)
copy
pinot-plugins/pinot-stream-ingestion/{pinot-kafka-2.0/src/main/java/org/apache/pinot/plugin/stream/kafka20
=>
pinot-kafka-3.0/src/main/java/org/apache/pinot/plugin/stream/kafka30}/KafkaStreamMetadataProvider.java
(98%)
copy
pinot-plugins/pinot-stream-ingestion/{pinot-kafka-2.0/src/test/java/org/apache/pinot/plugin/stream/kafka20
=>
pinot-kafka-3.0/src/test/java/org/apache/pinot/plugin/stream/kafka30}/KafkaPartitionLevelConsumerBackwardCompatibilityTest.java
(90%)
copy
pinot-plugins/pinot-stream-ingestion/{pinot-kafka-2.0/src/test/java/org/apache/pinot/plugin/stream/kafka20
=>
pinot-kafka-3.0/src/test/java/org/apache/pinot/plugin/stream/kafka30}/KafkaPartitionLevelConsumerTest.java
(99%)
copy
pinot-plugins/pinot-stream-ingestion/{pinot-kafka-2.0/src/test/java/org/apache/pinot/plugin/stream/kafka20
=>
pinot-kafka-3.0/src/test/java/org/apache/pinot/plugin/stream/kafka30}/KafkaPartitionLevelStreamConfigTest.java
(88%)
copy
pinot-plugins/pinot-stream-ingestion/{pinot-kafka-2.0/src/test/java/org/apache/pinot/plugin/stream/kafka20
=>
pinot-kafka-3.0/src/test/java/org/apache/pinot/plugin/stream/kafka30}/utils/MiniKafkaCluster.java
(86%)
copy {pinot-broker =>
pinot-plugins/pinot-stream-ingestion/pinot-kafka-3.0}/src/test/resources/log4j2.xml
(100%)
rename
pinot-plugins/pinot-stream-ingestion/{pinot-kafka-2.0/src/main/java/org/apache/pinot/plugin/stream/kafka20
=>
pinot-kafka-base/src/main/java/org/apache/pinot/plugin/stream/kafka}/KafkaConfigBackwardCompatibleUtils.java
(99%)
rename
pinot-plugins/pinot-stream-ingestion/{pinot-kafka-2.0/src/main/java/org/apache/pinot/plugin/stream/kafka20
=>
pinot-kafka-base/src/main/java/org/apache/pinot/plugin/stream/kafka}/KafkaConsumerPartitionLag.java
(96%)
rename
pinot-plugins/pinot-stream-ingestion/{pinot-kafka-2.0/src/main/java/org/apache/pinot/plugin/stream/kafka20
=>
pinot-kafka-base/src/main/java/org/apache/pinot/plugin/stream/kafka}/KafkaMessageBatch.java
(98%)
rename
pinot-plugins/pinot-stream-ingestion/{pinot-kafka-2.0/src/main/java/org/apache/pinot/plugin/stream/kafka20
=>
pinot-kafka-base/src/main/java/org/apache/pinot/plugin/stream/kafka}/KafkaPartitionLevelStreamConfig.java
(98%)
rename
pinot-plugins/pinot-stream-ingestion/{pinot-kafka-2.0/src/main/java/org/apache/pinot/plugin/stream/kafka20
=>
pinot-kafka-base/src/main/java/org/apache/pinot/plugin/stream/kafka}/KafkaSSLUtils.java
(99%)
rename
pinot-plugins/pinot-stream-ingestion/{pinot-kafka-2.0/src/main/java/org/apache/pinot/plugin/stream/kafka20
=>
pinot-kafka-base/src/main/java/org/apache/pinot/plugin/stream/kafka}/KafkaStreamMessageMetadata.java
(96%)
rename
pinot-plugins/pinot-stream-ingestion/{pinot-kafka-2.0/src/test/java/org/apache/pinot/plugin/stream/kafka20
=>
pinot-kafka-base/src/test/java/org/apache/pinot/plugin/stream/kafka}/KafkaSSLUtilsTest.java
(99%)
rename
pinot-plugins/pinot-stream-ingestion/{pinot-kafka-2.0/src/test/java/org/apache/pinot/plugin/stream/kafka20
=>
pinot-kafka-base/src/test/java/org/apache/pinot/plugin/stream/kafka}/utils/EmbeddedZooKeeper.java
(95%)
---------------------------------------------------------------------
To unsubscribe, e-mail: [email protected]
For additional commands, e-mail: [email protected]
