Bruno Cadonna created KAFKA-19110:
-------------------------------------
Summary: Add missing unit test for Streams-consumer integration
Key: KAFKA-19110
URL: https://issues.apache.org/jira/browse/KAFKA-19110
Project: Kafka
Issue Type: Test
Components: consumer, streams
Reporter: Bruno Cadonna
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)
