imcdo commented on code in PR #14524: URL: https://github.com/apache/kafka/pull/14524#discussion_r1357169852
########## tests/kafkatest/tests/core/consume_bench_test.py: ########## @@ -68,12 +67,21 @@ def produce_messages(self, topics, max_messages=10000): self.logger.debug("Produce workload finished") @cluster(num_nodes=10) - @matrix(topics=[["consume_bench_topic[0-5]"]], metadata_quorum=quorum.all_non_upgrade) # topic subscription - @matrix(topics=[["consume_bench_topic[0-5]:[0-4]"]], metadata_quorum=quorum.all_non_upgrade) # manual topic assignment - def test_consume_bench(self, topics, metadata_quorum=quorum.zk): + @matrix( + topics=[ + ["consume_bench_topic[0-5]"], + ["consume_bench_topic[0-5]:[0-4]"] + ], + metadata_quorum=quorum.all_non_upgrade, + use_new_coordinator=[True, False] + ) # topic subscription Review Comment: I think if its only temporary its probably best as suggested as it would be easiest to role back and has the least complexity. Yeah its a bit repetitive, but it wont get in the way of anyone trying to add configs in the next 2.5 quarters. If we need a full test analysis of the feature, we can use the ducktape globals, and just live with the zk test results. (and just not run them nightly, just when we want to validate). -- This is an automated message from the Apache Git Service. To respond to the message, please log on to GitHub and use the URL above to go to the specific comment. To unsubscribe, e-mail: jira-unsubscr...@kafka.apache.org For queries about this service, please contact Infrastructure at: us...@infra.apache.org