[
https://issues.apache.org/jira/browse/KAFKA-16639?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17850779#comment-17850779
]
Lianet Magrans commented on KAFKA-16639:
----------------------------------------
Hey [~chia7712] , totally agree. The PR in this ticket is ensuring the "create
request" part: IF the HBManager is polled when the member wants to leave, it
will create the leave request (no matter the in-flights). But we also need to
make sure that the manager is actually polled (as you had suggested initially,
but this PR ended up focusing on the create part as you said). Follow-up
comments related to that on KAFKA-15305
> AsyncKafkaConsumer#close does not send heartbeat to leave group
> ---------------------------------------------------------------
>
> Key: KAFKA-16639
> URL: https://issues.apache.org/jira/browse/KAFKA-16639
> Project: Kafka
> Issue Type: Bug
> Components: clients, consumer
> Reporter: Chia-Ping Tsai
> Assignee: TengYao Chi
> Priority: Critical
> Labels: kip-848-client-support
> Fix For: 3.8.0
>
>
> This bug can be reproduced by immediately closing a consumer which is just
> created.
> The root cause is that we skip the new heartbeat used to leave group when
> there is a in-flight heartbeat request
> ([https://github.com/apache/kafka/blob/5de5d967adffd864bad3ec729760a430253abf38/clients/src/main/java/org/apache/kafka/clients/consumer/internals/HeartbeatRequestManager.java#L212).]
> It seems to me the simple solution is that we create a heartbeat request when
> meeting above situation and then send it by pollOnClose
> ([https://github.com/apache/kafka/blob/5de5d967adffd864bad3ec729760a430253abf38/clients/src/main/java/org/apache/kafka/clients/consumer/internals/RequestManager.java#L62).]
>
--
This message was sent by Atlassian Jira
(v8.20.10#820010)
