[hotfix][pulsar] Fix the bug that can't consume messages all the time. (

apache#4125)
ic4y · Mar 23, 2023 · ab8e9e0 · ab8e9e0
1 parent b15e05a
commit ab8e9e0
Showing 1 changed file with 1 addition and 0 deletions.
diff --git a/...g/apache/seatunnel/connectors/seatunnel/pulsar/source/reader/PulsarSplitReaderThread.java b/...g/apache/seatunnel/connectors/seatunnel/pulsar/source/reader/PulsarSplitReaderThread.java
@@ -81,6 +81,7 @@ public void open() throws PulsarClientException {
         if (split.getLatestConsumedId() == null) {
             startCursor.seekPosition(consumer);
         }
+        this.running = true;
     }
 
     @Override