From 68f5bc19d36410d4325565003d24f6386796e83e Mon Sep 17 00:00:00 2001 From: Kirk True Date: Tue, 7 Oct 2025 08:54:06 -0700 Subject: [PATCH] Whitespace change --- .../kafka/clients/consumer/internals/AsyncKafkaConsumer.java | 1 + 1 file changed, 1 insertion(+) diff --git a/clients/src/main/java/org/apache/kafka/clients/consumer/internals/AsyncKafkaConsumer.java b/clients/src/main/java/org/apache/kafka/clients/consumer/internals/AsyncKafkaConsumer.java index 1380e9c5d6f..807a6545a3d 100644 --- a/clients/src/main/java/org/apache/kafka/clients/consumer/internals/AsyncKafkaConsumer.java +++ b/clients/src/main/java/org/apache/kafka/clients/consumer/internals/AsyncKafkaConsumer.java @@ -1837,6 +1837,7 @@ public class AsyncKafkaConsumer implements ConsumerDelegate { } log.trace("Polling for fetches with timeout {}", pollTimeout); + Timer pollTimer = time.timer(pollTimeout); wakeupTrigger.setFetchAction(fetchBuffer);