cadonna commented on code in PR #14746:
URL: https://github.com/apache/kafka/pull/14746#discussion_r1390948525
##########
clients/src/main/java/org/apache/kafka/clients/consumer/internals/PrototypeAsyncConsumer.java:
##########
@@ -335,10 +336,17 @@ public ConsumerRecords<K, V> poll(final Duration timeout)
{
throw new IllegalStateException("Consumer is not subscribed to
any topics or assigned any partitions");
}
+ final CompletableFuture<Void> wakeupFuture = setupWakeupTrigger();
Review Comment:
I needed to create a dedicated future since fetches are not passed to the
background thread as events since fetches happen continuously on the background
thread.
--
This is an automated message from the Apache Git Service.
To respond to the message, please log on to GitHub and use the
URL above to go to the specific comment.
To unsubscribe, e-mail: [email protected]
For queries about this service, please contact Infrastructure at:
[email protected]
