You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@pulsar.apache.org by ba...@apache.org on 2025/03/26 00:09:04 UTC
(pulsar) branch branch-3.3 updated: [improve][io] Remove sleep when sourceTask.poll of kafka return null (#24124)
This is an automated email from the ASF dual-hosted git repository.
baodi pushed a commit to branch branch-3.3
in repository https://gitbox.apache.org/repos/asf/pulsar.git
The following commit(s) were added to refs/heads/branch-3.3 by this push:
new ec1beeede88 [improve][io] Remove sleep when sourceTask.poll of kafka return null (#24124)
ec1beeede88 is described below
commit ec1beeede88d70b7d8924f422bd11419c5cb5af1
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());