[ https://issues.apache.org/jira/browse/KAFKA-16287?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ]
Kirk True updated KAFKA-16287: ------------------------------ 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. was: There is justified concern that the new threading model may not play well with "tricky" {{ConsumerRebalanceListener}} callbacks. We need to provide some assurance that it will support complicated patterns. # Design and implement test scenarios # Update and document any design changes with the callback sub-system where needed # Provide fix(es) to the {{AsyncKafkaConsumer}} implementation to abide by said design > Implement example test for common rebalance callback scenarios > -------------------------------------------------------------- > > Key: KAFKA-16287 > URL: https://issues.apache.org/jira/browse/KAFKA-16287 > Project: Kafka > Issue Type: Test > Components: clients, consumer > Reporter: Kirk True > Assignee: Lucas Brutschy > Priority: Blocker > Labels: callback, consumer-threading-refactor, integration-tests > Fix For: 3.8.0 > > > 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. -- This message was sent by Atlassian Jira (v8.20.10#820010)