cadonna commented on PR #14746: URL: https://github.com/apache/kafka/pull/14746#issuecomment-1814256948
@philipnee @kirktrue @lucasbru I am concerned that when one calls `wakeup()` the application thread might stay blocked in waiting for a non-empty fetch buffer. See https://github.com/apache/kafka/blob/a16cde3b1f67ea3248466444fd3562878428fecf/clients/src/main/java/org/apache/kafka/clients/consumer/internals/AsyncKafkaConsumer.java#L968 Currently, I do not know how to interrupt the application thread with the current code. I cannot do it in `AsyncKafkaConsumer#wakeup()` because I do not have a handle on the application thread and I cannot do it in `WakeupTrigger#maybeTriggerWakeup()` because there it is too late. Any ideas? -- 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: jira-unsubscr...@kafka.apache.org For queries about this service, please contact Infrastructure at: us...@infra.apache.org
