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

#4125)
apache · Mar 22, 2023 · a6705cc · a6705cc
1 parent 801642f
commit a6705cc
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