dajac commented on code in PR #14524:
URL: https://github.com/apache/kafka/pull/14524#discussion_r1356466186
##########
tests/kafkatest/tests/core/consume_bench_test.py:
##########
@@ -23,14 +23,14 @@
from kafkatest.services.trogdor.task_spec import TaskSpec
from kafkatest.services.trogdor.trogdor import TrogdorService
from kafkatest.services.zookeeper import ZookeeperService
-
+from kafkatest.services.kafka.util import skip_if_new_coordinator_and_zk
class ConsumeBenchTest(Test):
def __init__(self, test_context):
""":type test_context: ducktape.tests.test.TestContext"""
super(ConsumeBenchTest, self).__init__(test_context)
self.zk = ZookeeperService(test_context, num_nodes=3) if
quorum.for_test(test_context) == quorum.zk else None
- self.kafka = KafkaService(test_context, num_nodes=3, zk=self.zk)
+ self.kafka = KafkaService(test_context, num_nodes=3, zk=self.zk,)
Review Comment:
Do we need that extra `,`?
--
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: [email protected]
For queries about this service, please contact Infrastructure at:
[email protected]
