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)