[ 
https://issues.apache.org/jira/browse/KAFKA-16273?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17818210#comment-17818210
 ] 

Kirk True commented on KAFKA-16273:
-----------------------------------

There's an issue here in that the {{ConsumeBenchWorkloadService}} executes the 
{{Consumer.poll()}} method with a short timeout of 50 ms. There are several 
issues in the new consumer related to how it handles timeouts differently than 
the existing consumer. So until those issues are fixed, this might need to take 
the back burner.

> Update consume_bench_test.py to support KIP-848’s group protocol config
> -----------------------------------------------------------------------
>
>                 Key: KAFKA-16273
>                 URL: https://issues.apache.org/jira/browse/KAFKA-16273
>             Project: Kafka
>          Issue Type: Test
>          Components: clients, consumer, system tests
>    Affects Versions: 3.7.0
>            Reporter: Kirk True
>            Assignee: Kirk True
>            Priority: Blocker
>              Labels: kip-848-client-support, system-tests
>             Fix For: 3.8.0
>
>
> This task is to update the test method(s) in {{consume_bench_test.py}} to 
> support the {{group.protocol}} configuration introduced in 
> [KIP-848|https://cwiki.apache.org/confluence/display/KAFKA/KIP-848%3A+The+Next+Generation+of+the+Consumer+Rebalance+Protocol]
>  by adding an optional {{group_protocol}} argument to the tests and matrixes.



--
This message was sent by Atlassian Jira
(v8.20.10#820010)

Reply via email to