Skip to content

Commit 50c838d

Browse files
committed
Use test id as client.id
1 parent bf3a2da commit 50c838d

File tree

1 file changed

+3
-0
lines changed

1 file changed

+3
-0
lines changed

tests/soak/soakclient.py

Lines changed: 3 additions & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -428,6 +428,7 @@ def filter_config(conf, filter_out, strip_prefix):
428428

429429
# Create topic (might already exist)
430430
aconf = filter_config(conf, ["consumer.", "producer."], "admin.")
431+
aconf['client.id'] = self.testid
431432
self.create_topic(self.topic, aconf)
432433

433434
#
@@ -439,13 +440,15 @@ def filter_config(conf, filter_out, strip_prefix):
439440
# Producer
440441
pconf = filter_config(conf, ["consumer.", "admin."], "producer.")
441442
pconf['error_cb'] = self.producer_error_cb
443+
pconf['client.id'] = self.testid
442444
self.producer = Producer(pconf)
443445

444446
# Consumer
445447
cconf = filter_config(conf, ["producer.", "admin."], "consumer.")
446448
cconf['error_cb'] = self.consumer_error_cb
447449
cconf['on_commit'] = self.consumer_commit_cb
448450
self.logger.info("consumer: using group.id {}".format(cconf['group.id']))
451+
cconf['client.id'] = self.testid
449452
self.consumer = Consumer(cconf)
450453

451454
# Initialize some counters to zero to make them appear in the metrics

0 commit comments

Comments
 (0)