[improve][io] Remove sleep when sourceTask.poll of kafka return null (apache#24124)

shibd · nikhil-ctds · commit 863d351aec06 · 2025-03-29T12:04:59.000+05:30
(cherry picked from commit d0c996e) (cherry picked from commit 0782b7d)
diff --git a/pulsar-io/kafka-connect-adaptor/src/main/java/org/apache/pulsar/io/kafka/connect/AbstractKafkaConnectSource.java b/pulsar-io/kafka-connect-adaptor/src/main/java/org/apache/pulsar/io/kafka/connect/AbstractKafkaConnectSource.java
@@ -169,7 +169,6 @@ public synchronized Record<T> read() throws Exception {
                 flushFuture = new CompletableFuture<>();
                 List<SourceRecord> recordList = sourceTask.poll();
                 if (recordList == null || recordList.isEmpty()) {
-                    Thread.sleep(1000);
                     continue;
                 }
                 outstandingRecords.addAndGet(recordList.size());

Original file line number	Diff line number	Diff line change
`@@ -169,7 +169,6 @@ public synchronized Record<T> read() throws Exception {`
`169`	`169`	`flushFuture = new CompletableFuture<>();`
`170`	`170`	`List<SourceRecord> recordList = sourceTask.poll();`
`171`	`171`	`if (recordList == null \|\| recordList.isEmpty()) {`
`172`		`- Thread.sleep(1000);`
`173`	`172`	`continue;`
`174`	`173`	`}`
`175`	`174`	`outstandingRecords.addAndGet(recordList.size());`