(pinot) branch master updated: Remove Kafka 0.9 plugin. (#13893)

[jackie]

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 <abhishek.sha...@spothero.com>
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: commits-unsubscr...@pinot.apache.org
For additional commands, e-mail: commits-h...@pinot.apache.org