(pulsar) branch branch-4.0 updated: [improve][io] Remove sleep when sourceTask.poll of kafka return null (#24124)

[baodi]

This is an automated email from the ASF dual-hosted git repository.

baodi pushed a commit to branch branch-4.0
in repository https://gitbox.apache.org/repos/asf/pulsar.git


The following commit(s) were added to refs/heads/branch-4.0 by this push:
     new 0782b7d7150 [improve][io] Remove sleep when sourceTask.poll of kafka 
return null (#24124)
0782b7d7150 is described below

commit 0782b7d71502abac86d2059ca07c0e9e39c18a75
Author: Baodi Shi <ba...@apache.org>
AuthorDate: Wed Mar 26 08:06:38 2025 +0800

    [improve][io] Remove sleep when sourceTask.poll of kafka return null 
(#24124)
    
    (cherry picked from commit d0c996e9f80f7297ab7539b8bc09e7e6ec607651)
---
 .../org/apache/pulsar/io/kafka/connect/AbstractKafkaConnectSource.java   | 1 -
 1 file changed, 1 deletion(-)

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
index 36d2b4bcdbf..a7bf32d9bc7 100644
--- 
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 abstract class AbstractKafkaConnectSource<T> 
implements Source<T> {
                 flushFuture = new CompletableFuture<>();
                 List<SourceRecord> recordList = sourceTask.poll();
                 if (recordList == null || recordList.isEmpty()) {
-                    Thread.sleep(1000);
                     continue;
                 }
                 outstandingRecords.addAndGet(recordList.size());