[KAFKA-16287] Implement example test for common rebalance callback scenarios

• Type: Test
• Status: Resolved
• Priority: Blocker
• Resolution: Fixed
• Affects Version/s: 3.7.0
• Fix Version/s: 3.8.0
• Component/s: clients, consumer
• Labels: callback consumer-threading-refactor integration-tests
• Assignee: Lucas Brutschy
• Reporter: Kirk True
• Created: 20/Feb/24 19:53
• Updated: 15/May/24 09:12
• Resolved: 23/Feb/24 09:54

Description

We need to add an example test to the PlaintextConsumerTest that tests a common ConsumerRebalanceListener use case. For example, create an integration test that invokes the Consumer API to commit offsets in the onPartitionsRevoked callback.

Please develop this test in a reasonably general way with a view to using it as a template from which other tests can be created later. Eventually we will need to have a comprehensive set of tests that cover all the basic use cases.

Issue Links

• blocks: KAFKA-16111 Implement tests for tricky rebalance callback scenarios
• links to: GitHub Pull Request #15408