lucasbru opened a new pull request, #21642: URL: https://github.com/apache/kafka/pull/21642
Depends on #21641. This adds an integration test that reproduces the scenario where log compaction removes the GroupMetadata tombstone from __consumer_offsets, leaving orphan offset commit records before the streams group records. On broker restart, replaying these records creates a simple classic group that the streams group records must handle. The test commits an offset for an "orphan" topic using the classic group's ID, then migrates to the streams protocol. After triggering log compaction to remove the tombstone, it restarts the broker and verifies the streams group still works. This exercises the isSimpleGroup() fix in getOrMaybeCreatePersistedStreamsGroup. Also adds shutdownBroker/startBroker methods to EmbeddedKafkaCluster to enable broker restart within tests. -- 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]
