[
https://issues.apache.org/jira/browse/KAFKA-19164?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
David Jacot resolved KAFKA-19164.
---------------------------------
Fix Version/s: 4.0.1
4.1.0
Resolution: Fixed
> 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
> Priority: Major
> Fix For: 4.0.1, 4.1.0
>
>
> 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)
