[jira] [Created] (KAFKA-19164) New group coordinator won't delete groups with previously pending transactional offsets that were deleted

Wed, 16 Apr 2025 10:37:12 -0700 

Sean Quah created KAFKA-19164:
---------------------------------

             Summary: New group coordinator won't delete groups with previously 
pending transactional offsets that were deleted
                 Key: KAFKA-19164
                 URL: https://issues.apache.org/jira/browse/KAFKA-19164
             Project: Kafka
          Issue Type: Bug
          Components: group-coordinator
            Reporter: Sean Quah
            Assignee: Sean Quah


This bug is partially masked by KAFKA-19163.

We track which groups have pending transactional offsets in the 
`openTransactionsByGroup` map.
https://github.com/apache/kafka/blob/6e26ec06bb895ff236cf1a402827d95e8d3c8c4d/group-coordinator/src/main/java/org/apache/kafka/coordinator/group/OffsetMetadataManager.java#L198

When committing or aborting a transaction, we remove entries from the map.
https://github.com/apache/kafka/blob/6e26ec06bb895ff236cf1a402827d95e8d3c8c4d/group-coordinator/src/main/java/org/apache/kafka/coordinator/group/OffsetMetadataManager.java#L1046-L1054

However, when deleting the last offset from a transaction, we lose track of the 
groups involved and no longer remove entries from the `openTransactionsByGroup` 
map.
https://github.com/apache/kafka/blob/6e26ec06bb895ff236cf1a402827d95e8d3c8c4d/group-coordinator/src/main/java/org/apache/kafka/coordinator/group/OffsetMetadataManager.java#L1014-L1023



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

Reply via email to