[
https://issues.apache.org/jira/browse/KAFKA-19110?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17942229#comment-17942229
]
PoAn Yang commented on KAFKA-19110:
-----------------------------------
[~cadonna] Thank you. If this's not urgent, I can handle it this weekend.
> 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)
