[ https://issues.apache.org/jira/browse/KAFKA-16037?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ]
Kirk True updated KAFKA-16037: ------------------------------ Description: This task is to parameterize the system tests so that they execute the Consumer for both of the group protocols introduced in [KIP-848|https://cwiki.apache.org/confluence/display/KAFKA/KIP-848%3A+The+Next+Generation+of+the+Consumer+Rebalance+Protocol]: * classic * consumer This is done in a few steps... First, update the Java-based VerifiableConsumer to support passing in the group protocol by adding a new group_protocol parameter to the relevant parameterized tests: {code:python} @matrix( metadata_quorum=[quorum.isolated_kraft], use_new_coordinator=[True], group_protocol=["classic", "consumer"] ) def test_the_consumer(self, group_protocol, metadata_quorum=quorum.zk, use_new_coordinator=False): consumer = self.setup_consumer("my_topic", group_protocol=group_protocol) {code} The VerifiableConsumer class in Python represents the calling of the VerifiableConsumer class in Java. The was:This task is to parameterize the tests to run twice: both for the old and the new Consumer. > Upgrade existing system tests to use new consumer > ------------------------------------------------- > > Key: KAFKA-16037 > URL: https://issues.apache.org/jira/browse/KAFKA-16037 > Project: Kafka > Issue Type: Test > Components: clients, consumer, system tests > Reporter: Kirk True > Assignee: Kirk True > Priority: Blocker > Labels: kip-848-client-support, system-tests > Fix For: 3.8.0 > > > This task is to parameterize the system tests so that they execute the > Consumer for both of the group protocols introduced in > [KIP-848|https://cwiki.apache.org/confluence/display/KAFKA/KIP-848%3A+The+Next+Generation+of+the+Consumer+Rebalance+Protocol]: > * classic > * consumer > This is done in a few steps... > First, update the Java-based VerifiableConsumer to support passing in the > group protocol > by adding a new group_protocol parameter to the relevant parameterized tests: > {code:python} > @matrix( > metadata_quorum=[quorum.isolated_kraft], > use_new_coordinator=[True], > group_protocol=["classic", "consumer"] > ) > def test_the_consumer(self, group_protocol, metadata_quorum=quorum.zk, > use_new_coordinator=False): > consumer = self.setup_consumer("my_topic", group_protocol=group_protocol) > {code} > The VerifiableConsumer class in Python represents the calling of the > VerifiableConsumer class in Java. The -- This message was sent by Atlassian Jira (v8.20.10#820010)