apoorvmittal10 commented on PR #17431:
URL: https://github.com/apache/kafka/pull/17431#issuecomment-2404447589
> Thanks @apoorvmittal10!
>
> This bit at the start of `initiateClose()` is a bit confounding:
>
> ```java
> // If we never fetched a subscription, we can't really push anything.
> if (lastRequestMs == 0) {
> log.debug("Telemetry subscription not loaded, not attempting
terminating push");
> return;
> }
> ```
>
> To get as far as the `terminalPushInProgress.await()` line, `lastRequest`
would have to be non-zero, right? In the PR summary, it mentions that the
consumer closed immediately, but since `lastRequest` was non-zero, did it
receive a subscription response?
>
> Sorry, I may be interpreting things too literally 🤷♂️
>
> Thanks!
Yeah, it did get a subscription reply. But there is a delay in poll start
from heartbeat thread which makes the call stuck, sometimes.
--
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
