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 145a8c00a1 Clean up v0_deprecated batch ingestion jobs (#10532)
add 513fa3147b Deprecate kafka 0.9 support (#10522)
No new revisions were added by this update.
Summary of changes:
pinot-distribution/pinot-assembly.xml | 8 -
.../pinot-kafka-0.9/README.md | 24 --
.../pinot-stream-ingestion/pinot-kafka-0.9/pom.xml | 161 --------
.../plugin/stream/kafka09/ConsumerAndIterator.java | 58 ---
.../plugin/stream/kafka09/KafkaBrokerWrapper.java | 81 ----
.../stream/kafka09/KafkaConnectionHandler.java | 442 ---------------------
.../stream/kafka09/KafkaConsumerFactory.java | 53 ---
.../stream/kafka09/KafkaConsumerManager.java | 193 ---------
.../stream/kafka09/KafkaHighLevelStreamConfig.java | 161 --------
.../stream/kafka09/KafkaLowLevelStreamConfig.java | 146 -------
.../kafka09/KafkaPartitionLevelConsumer.java | 146 -------
.../stream/kafka09/KafkaSimpleConsumerFactory.java | 30 --
.../kafka09/KafkaSimpleConsumerFactoryImpl.java | 32 --
.../stream/kafka09/KafkaStreamLevelConsumer.java | 121 ------
.../kafka09/KafkaStreamMetadataProvider.java | 232 -----------
.../stream/kafka09/SimpleConsumerFactory.java | 29 --
.../stream/kafka09/SimpleConsumerMessageBatch.java | 67 ----
.../stream/kafka09/server/KafkaDataProducer.java | 57 ---
.../kafka09/server/KafkaDataServerStartable.java | 118 ------
...g.apache.pinot.spi.stream.StreamConsumerFactory | 19 -
.../kafka09/KafkaLowLevelStreamConfigTest.java | 163 --------
.../kafka09/KafkaPartitionLevelConsumerTest.java | 357 -----------------
.../pinot-kafka-0.9/src/test/resources/log4j2.xml | 36 --
pinot-plugins/pinot-stream-ingestion/pom.xml | 1 -
24 files changed, 2735 deletions(-)
delete mode 100644
pinot-plugins/pinot-stream-ingestion/pinot-kafka-0.9/README.md
delete mode 100644 pinot-plugins/pinot-stream-ingestion/pinot-kafka-0.9/pom.xml
delete mode 100644
pinot-plugins/pinot-stream-ingestion/pinot-kafka-0.9/src/main/java/org/apache/pinot/plugin/stream/kafka09/ConsumerAndIterator.java
delete mode 100644
pinot-plugins/pinot-stream-ingestion/pinot-kafka-0.9/src/main/java/org/apache/pinot/plugin/stream/kafka09/KafkaBrokerWrapper.java
delete mode 100644
pinot-plugins/pinot-stream-ingestion/pinot-kafka-0.9/src/main/java/org/apache/pinot/plugin/stream/kafka09/KafkaConnectionHandler.java
delete mode 100644
pinot-plugins/pinot-stream-ingestion/pinot-kafka-0.9/src/main/java/org/apache/pinot/plugin/stream/kafka09/KafkaConsumerFactory.java
delete mode 100644
pinot-plugins/pinot-stream-ingestion/pinot-kafka-0.9/src/main/java/org/apache/pinot/plugin/stream/kafka09/KafkaConsumerManager.java
delete mode 100644
pinot-plugins/pinot-stream-ingestion/pinot-kafka-0.9/src/main/java/org/apache/pinot/plugin/stream/kafka09/KafkaHighLevelStreamConfig.java
delete mode 100644
pinot-plugins/pinot-stream-ingestion/pinot-kafka-0.9/src/main/java/org/apache/pinot/plugin/stream/kafka09/KafkaLowLevelStreamConfig.java
delete mode 100644
pinot-plugins/pinot-stream-ingestion/pinot-kafka-0.9/src/main/java/org/apache/pinot/plugin/stream/kafka09/KafkaPartitionLevelConsumer.java
delete mode 100644
pinot-plugins/pinot-stream-ingestion/pinot-kafka-0.9/src/main/java/org/apache/pinot/plugin/stream/kafka09/KafkaSimpleConsumerFactory.java
delete mode 100644
pinot-plugins/pinot-stream-ingestion/pinot-kafka-0.9/src/main/java/org/apache/pinot/plugin/stream/kafka09/KafkaSimpleConsumerFactoryImpl.java
delete mode 100644
pinot-plugins/pinot-stream-ingestion/pinot-kafka-0.9/src/main/java/org/apache/pinot/plugin/stream/kafka09/KafkaStreamLevelConsumer.java
delete mode 100644
pinot-plugins/pinot-stream-ingestion/pinot-kafka-0.9/src/main/java/org/apache/pinot/plugin/stream/kafka09/KafkaStreamMetadataProvider.java
delete mode 100644
pinot-plugins/pinot-stream-ingestion/pinot-kafka-0.9/src/main/java/org/apache/pinot/plugin/stream/kafka09/SimpleConsumerFactory.java
delete mode 100644
pinot-plugins/pinot-stream-ingestion/pinot-kafka-0.9/src/main/java/org/apache/pinot/plugin/stream/kafka09/SimpleConsumerMessageBatch.java
delete mode 100644
pinot-plugins/pinot-stream-ingestion/pinot-kafka-0.9/src/main/java/org/apache/pinot/plugin/stream/kafka09/server/KafkaDataProducer.java
delete mode 100644
pinot-plugins/pinot-stream-ingestion/pinot-kafka-0.9/src/main/java/org/apache/pinot/plugin/stream/kafka09/server/KafkaDataServerStartable.java
delete mode 100644
pinot-plugins/pinot-stream-ingestion/pinot-kafka-0.9/src/main/resources/META-INF/services/org.apache.pinot.spi.stream.StreamConsumerFactory
delete mode 100644
pinot-plugins/pinot-stream-ingestion/pinot-kafka-0.9/src/test/java/org/apache/pinot/plugin/stream/kafka09/KafkaLowLevelStreamConfigTest.java
delete mode 100644
pinot-plugins/pinot-stream-ingestion/pinot-kafka-0.9/src/test/java/org/apache/pinot/plugin/stream/kafka09/KafkaPartitionLevelConsumerTest.java
delete mode 100644
pinot-plugins/pinot-stream-ingestion/pinot-kafka-0.9/src/test/resources/log4j2.xml
---------------------------------------------------------------------
To unsubscribe, e-mail: commits-unsubscr...@pinot.apache.org
For additional commands, e-mail: commits-h...@pinot.apache.org
