Philip Nee created KAFKA-15548:
----------------------------------
Summary: Handling close() properly
Key: KAFKA-15548
URL: https://issues.apache.org/jira/browse/KAFKA-15548
Project: Kafka
Issue Type: Bug
Components: consumer
Reporter: Philip Nee
Assignee: Philip Nee
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)