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