This is an automated email from the ASF dual-hosted git repository.
jackie pushed a commit to branch master
in repository https://gitbox.apache.org/repos/asf/pinot.git
The following commit(s) were added to refs/heads/master by this push:
new 7d824749d2 Remove Kafka 0.9 plugin. (#13893)
7d824749d2 is described below
commit 7d824749d2d553ef81f0001352e2ce1cc5a98e72
Author: Abhishek Sharma <[email protected]>
AuthorDate: Tue Aug 27 17:46:04 2024 -0400
Remove Kafka 0.9 plugin. (#13893)
---
pinot-spi/src/main/java/org/apache/pinot/spi/plugin/PluginManager.java | 2 --
.../java/org/apache/pinot/spi/stream/StreamDataServerStartable.java | 2 +-
.../src/test/java/org/apache/pinot/spi/plugin/PluginManagerTest.java | 3 ---
3 files changed, 1 insertion(+), 6 deletions(-)
diff --git
a/pinot-spi/src/main/java/org/apache/pinot/spi/plugin/PluginManager.java
b/pinot-spi/src/main/java/org/apache/pinot/spi/plugin/PluginManager.java
index 3c87f5407f..8d54f21259 100644
--- a/pinot-spi/src/main/java/org/apache/pinot/spi/plugin/PluginManager.java
+++ b/pinot-spi/src/main/java/org/apache/pinot/spi/plugin/PluginManager.java
@@ -81,8 +81,6 @@ public class PluginManager {
put("org.apache.pinot.filesystem.LocalPinotFS",
"org.apache.pinot.spi.filesystem.LocalPinotFS");
// StreamConsumerFactory
- put("org.apache.pinot.core.realtime.impl.kafka.KafkaConsumerFactory",
- "org.apache.pinot.plugin.stream.kafka09.KafkaConsumerFactory");
put("org.apache.pinot.core.realtime.impl.kafka2.KafkaConsumerFactory",
"org.apache.pinot.plugin.stream.kafka20.KafkaConsumerFactory");
}
diff --git
a/pinot-spi/src/main/java/org/apache/pinot/spi/stream/StreamDataServerStartable.java
b/pinot-spi/src/main/java/org/apache/pinot/spi/stream/StreamDataServerStartable.java
index 2cefe507f1..f1ce97cbdf 100644
---
a/pinot-spi/src/main/java/org/apache/pinot/spi/stream/StreamDataServerStartable.java
+++
b/pinot-spi/src/main/java/org/apache/pinot/spi/stream/StreamDataServerStartable.java
@@ -25,7 +25,7 @@ import java.util.Properties;
* StreamDataServerStartable is the interface for stream data sources.
* Each stream data connector should implement a mock/wrapper of the data
server.
*
- * E.g. KafkaDataServerStartable is a wrapper class of Kafka 0.9 broker.
+ * E.g. KafkaDataServerStartable is a wrapper class of Kafka 2.x broker.
*
*/
public interface StreamDataServerStartable {
diff --git
a/pinot-spi/src/test/java/org/apache/pinot/spi/plugin/PluginManagerTest.java
b/pinot-spi/src/test/java/org/apache/pinot/spi/plugin/PluginManagerTest.java
index fce6d245be..e86d91a267 100644
--- a/pinot-spi/src/test/java/org/apache/pinot/spi/plugin/PluginManagerTest.java
+++ b/pinot-spi/src/test/java/org/apache/pinot/spi/plugin/PluginManagerTest.java
@@ -190,9 +190,6 @@ public class PluginManagerTest {
"org.apache.pinot.spi.filesystem.LocalPinotFS");
// StreamConsumerFactory
- Assert.assertEquals(PluginManager
-
.loadClassWithBackwardCompatibleCheck("org.apache.pinot.core.realtime.impl.kafka.KafkaConsumerFactory"),
- "org.apache.pinot.plugin.stream.kafka09.KafkaConsumerFactory");
Assert.assertEquals(PluginManager
.loadClassWithBackwardCompatibleCheck("org.apache.pinot.core.realtime.impl.kafka2.KafkaConsumerFactory"),
"org.apache.pinot.plugin.stream.kafka20.KafkaConsumerFactory");
---------------------------------------------------------------------
To unsubscribe, e-mail: [email protected]
For additional commands, e-mail: [email protected]
