Remove pulsar high level consumer implementation

apache · Aug 11, 2023 · 0fa99a1 · 0fa99a1
1 parent 60f2269
commit 0fa99a1
Show file tree

Hide file tree

Showing 3 changed files with 1 addition and 308 deletions.
diff --git a/...not-pulsar/src/main/java/org/apache/pinot/plugin/stream/pulsar/PulsarConsumerFactory.java b/...not-pulsar/src/main/java/org/apache/pinot/plugin/stream/pulsar/PulsarConsumerFactory.java
@@ -40,7 +40,7 @@ public PartitionLevelConsumer createPartitionLevelConsumer(String clientId, int
   @Override
   public StreamLevelConsumer createStreamLevelConsumer(String clientId, String tableName, Set<String> fieldsToRead,
       String groupId) {
-    return new PulsarStreamLevelConsumer(clientId, tableName, _streamConfig, fieldsToRead, groupId);
+    throw new UnsupportedOperationException("Apache pinot no longer support high level consumer");
   }
 
   @Override

diff --git a/...pulsar/src/main/java/org/apache/pinot/plugin/stream/pulsar/PulsarStreamLevelConsumer.java b/...pulsar/src/main/java/org/apache/pinot/plugin/stream/pulsar/PulsarStreamLevelConsumer.java
diff --git a/...src/main/java/org/apache/pinot/plugin/stream/pulsar/PulsarStreamLevelConsumerManager.java b/...src/main/java/org/apache/pinot/plugin/stream/pulsar/PulsarStreamLevelConsumerManager.java