Skip to content

Commit 2153fe2

Browse files
Remove statistics configuration for ShareConsumer to prevent crashes
1 parent 05dddbd commit 2153fe2

1 file changed

Lines changed: 6 additions & 2 deletions

File tree

tests/soak/soakclient.py

Lines changed: 6 additions & 2 deletions
Original file line numberDiff line numberDiff line change
@@ -629,8 +629,12 @@ def filter_config(conf, filter_out, strip_prefix):
629629

630630
sconf = filter_config(conf, ["consumer.", "producer.", "admin."], "share.")
631631
sconf['error_cb'] = self.share_error_cb
632-
sconf['stats_cb'] = self.stats_cb
633-
sconf['statistics.interval.ms'] = 120000
632+
# Share consumer rejects `statistics.interval.ms` (librdkafka
633+
# `dev_kip-932_queues-for-kafka` PR #5469). Strip the stats
634+
# wiring inherited from the parent conf so ShareConsumer()
635+
# doesn't crash with `_INVALID_ARG`.
636+
sconf.pop('statistics.interval.ms', None)
637+
sconf.pop('stats_cb', None)
634638
sconf['client.id'] = self.testid
635639

636640
# Always set a share-specific group.id.

0 commit comments

Comments
 (0)