[INLONG-7940][Manager] Use pulsar subscriptions and specify subscript…

…ion offset in pulsar connector
apache · May 8, 2023 · 450742e · 450742e
1 parent 2431f2f
commit 450742e
Show file tree

Hide file tree

Showing 2 changed files with 4 additions and 4 deletions.
diff --git a/...mon/src/test/java/org/apache/inlong/sort/protocol/node/extract/PulsarExtractNodeTest.java b/...mon/src/test/java/org/apache/inlong/sort/protocol/node/extract/PulsarExtractNodeTest.java
@@ -50,7 +50,7 @@ public Node getTestObject() {
                 format,
                 "earliest",
                 null,
-                null,
-                null);
+                "subscription",
+                "earliest");
     }
 }
diff --git a/inlong-sort/sort-core/src/test/java/org/apache/inlong/sort/parser/PulsarSqlParserTest.java b/inlong-sort/sort-core/src/test/java/org/apache/inlong/sort/parser/PulsarSqlParserTest.java
@@ -74,8 +74,8 @@ public PulsarExtractNode buildPulsarExtractNode() {
                 format,
                 "earliest",
                 null,
-                null,
-                null);
+                "test",
+                "earliest");
     }
 
     private NodeRelation buildNodeRelation(List<Node> inputs, List<Node> outputs) {