You are viewing a plain text version of this content. The canonical link for it is here.

Posted to jira@kafka.apache.org by "Lianet Magrans (Jira)" <ji...@apache.org> on 2023/10/05 14:03:00 UTC

[jira] [Commented] (KAFKA-15548) Handling close() properly

    [ https://issues.apache.org/jira/browse/KAFKA-15548?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17772227#comment-17772227 ] 

Lianet Magrans commented on KAFKA-15548:
----------------------------------------

Hey [~pnee] , this task already existed here https://issues.apache.org/jira/browse/KAFKA-15540 (Take whichever you want but let's make sure we cover the details explained in both descriptions and mark the dup)

> Handling close() properly
> -------------------------
>
>                 Key: KAFKA-15548
>                 URL: https://issues.apache.org/jira/browse/KAFKA-15548
>             Project: Kafka
>          Issue Type: Sub-task
>          Components: consumer
>            Reporter: Philip Nee
>            Assignee: Philip Nee
>            Priority: Major
>              Labels: consumer-threading-refactor
>
> Upon closing we need to:
>  # Complete pending commits
>  # Auto-commit if needed
>  # Send the last GroupConsumerHeartbeatRequest with epoch = -1 to leave the group
>  # poll the NetworkClient to complete pending I/O



--
This message was sent by Atlassian Jira
(v8.20.10#820010)