[jira] [Created] (KAFKA-19110) Add missing unit test for Streams-consumer integration

["Bruno Cadonna (Jira)" <ji...@apache.org>]

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)