[
https://issues.apache.org/jira/browse/KAFKA-19110?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17942141#comment-17942141
]
Bruno Cadonna commented on KAFKA-19110:
---------------------------------------
[~yangpoan] I checked the planned refactoring and I realized that it does not
affect the missing unit tests too much. If you are still interested, you are
more than welcome to assign this ticket to you and add the unit tests.
> Add missing unit test for Streams-consumer integration
> -------------------------------------------------------
>
> Key: KAFKA-19110
> URL: https://issues.apache.org/jira/browse/KAFKA-19110
> Project: Kafka
> Issue Type: Sub-task
> Components: consumer, streams
> Reporter: Bruno Cadonna
> Assignee: Bruno Cadonna
> Priority: Major
>
> PR https://github.com/apache/kafka/pull/19377 adds the integration of Streams
> with the async Kafka consumer for the implementation of the new Streams
> rebalance protocol specified in
> [KIP-1071|https://cwiki.apache.org/confluence/display/KAFKA/KIP-1071%3A+Streams+Rebalance+Protocol].
> However, the PR misses some unit tests.
> Specifically:
> * Construct `AsyncKafkaConsumer` constructor and verify that the
> `RequestManagers.supplier()` contains Streams-specific data structures.
> * Verify that `RequestManagers` constructs the Streams request managers
> correctly
> * Test `StreamsGroupHeartbeatManager#resetPollTimer()`
> * Test changes `ApplicationEventProcessor`
> * Test `DefaultStreamsGroupRebalanceCallbacks`
> * Test changes in `StreamThread`
--
This message was sent by Atlassian Jira
(v8.20.10#820010)
