lucasbru opened a new pull request, #21641: URL: https://github.com/apache/kafka/pull/21641
During replay of the __consumer_offsets topic, offset commit records can appear before streams group records, for example after log compaction. When OffsetMetadataManager replays an offset commit for a group that doesn't exist yet, it automatically creates a simple ClassicGroup to hold the offsets. When the streams group records are subsequently replayed, getOrMaybeCreatePersistedStreamsGroup fails with "Group X is not a streams group" because it does not handle simple classic groups. This adds handling for simple classic groups in getOrMaybeCreatePersistedStreamsGroup, matching the existing pattern in getOrMaybeCreatePersistedConsumerGroup. Simple classic groups have no backing records in __consumer_offsets and can safely be replaced. -- This is an automated message from the Apache Git Service. To respond to the message, please log on to GitHub and use the URL above to go to the specific comment. To unsubscribe, e-mail: [email protected] For queries about this service, please contact Infrastructure at: [email protected]
