KAFKA-17879 test_performance_services.py should use DEV version to run kafka service (#17606)

Reviewers: Chia-Ping Tsai <chia7712@gmail.com>
This commit is contained in:
Yung 2024-10-28 04:32:06 +08:00 committed by GitHub
parent 7fe009b2e7
commit 24689dc6ab
No known key found for this signature in database
GPG Key ID: B5690EEEBB952194
1 changed files with 1 additions and 1 deletions

View File

@ -54,7 +54,7 @@ class PerformanceServiceTest(Test):
version = KafkaVersion(version) version = KafkaVersion(version)
self.kafka = KafkaService( self.kafka = KafkaService(
self.test_context, 1, self.test_context, 1,
self.zk, topics={self.topic: {'partitions': 1, 'replication-factor': 1}}, version=version) self.zk, topics={self.topic: {'partitions': 1, 'replication-factor': 1}}, version=DEV_BRANCH)
self.kafka.start() self.kafka.start()
# check basic run of producer performance # check basic run of producer performance