[jira] [Created] (KAFKA-15696) Revoke partitions on Consumer.close()

["Kirk True (Jira)" <ji...@apache.org>]

Kirk True created KAFKA-15696:
---------------------------------

             Summary: Revoke partitions on Consumer.close()
                 Key: KAFKA-15696
                 URL: https://issues.apache.org/jira/browse/KAFKA-15696
             Project: Kafka
          Issue Type: Sub-task
          Components: clients, consumer
            Reporter: Kirk True
            Assignee: Philip Nee


Upon closing of the {{Consumer}} we need to:
 # Complete pending commits
 # Revoke assignment (Note that the revocation involves stop fetching, committing offsets if auto-commit enabled and invoking the onPartitionsRevoked callback)
 # Send the last GroupConsumerHeartbeatRequest with epoch = -1 to leave the group (or -2 if static member)
 # Close any fetch sessions on the brokers
 # Poll the NetworkClient to complete pending I/O

There is a mechanism introduced in PR [14406|https://github.com/apache/kafka/pull/14406] that allows for performing network I/O on shutdown. The new method {{DefaultBackgroundThread.runAtClose()}} will be executed when {{Consumer.close()}} is invoked.



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