You are viewing a plain text version of this content. The canonical link for it is here.
Posted to jira@kafka.apache.org by "Kirk True (Jira)" <ji...@apache.org> on 2024/02/20 19:58:00 UTC

[jira] [Updated] (KAFKA-16287) Implement example test for common rebalance callback scenarios

     [ 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)