17:08 $ swh counters -C ~/.config/swh/counters.yml journal-client
{'brokers': ['kafka1.internal.softwareheritage.org:9094', 'kafka2.internal.softwareheritage.org:9094', 'kafka3.internal.softwareheritage.org:9094', 'kafka4.internal.softwareheritage.org:9094'], 'prefix': 'swh.journal.objects', 'group_id': 'anlambert.origin_counts.dev4', 'object_types': ['origin'], 'batch_size': 1000, 'sasl.mechanism': 'SCRAM-SHA-256', 'security.protocol': 'SASL_SSL', 'sasl.username': 'mirror-test-ro', 'sasl.password': '**********', 'stop_after_objects': None}
Traceback (most recent call last):
File "/home/anlambert/.virtualenvs/swh/bin/swh", line 33, in <module>
sys.exit(load_entry_point('swh.core', 'console_scripts', 'swh')())
File "/home/anlambert/swh/swh-environment/swh-core/swh/core/cli/__init__.py", line 184, in main
return swh(auto_envvar_prefix="SWH")
File "/home/anlambert/.virtualenvs/swh/lib/python3.9/site-packages/click/core.py", line 1130, in __call__
return self.main(*args, **kwargs)
File "/home/anlambert/.virtualenvs/swh/lib/python3.9/site-packages/click/core.py", line 1055, in main
rv = self.invoke(ctx)
File "/home/anlambert/.virtualenvs/swh/lib/python3.9/site-packages/click/core.py", line 1657, in invoke
return _process_result(sub_ctx.command.invoke(sub_ctx))
File "/home/anlambert/.virtualenvs/swh/lib/python3.9/site-packages/click/core.py", line 1657, in invoke
return _process_result(sub_ctx.command.invoke(sub_ctx))
File "/home/anlambert/.virtualenvs/swh/lib/python3.9/site-packages/click/core.py", line 1404, in invoke
return ctx.invoke(self.callback, **ctx.params)
File "/home/anlambert/.virtualenvs/swh/lib/python3.9/site-packages/click/core.py", line 760, in invoke
return __callback(*args, **kwargs)
File "/home/anlambert/.virtualenvs/swh/lib/python3.9/site-packages/click/decorators.py", line 26, in new_func
return f(get_current_context(), *args, **kwargs)
File "/home/anlambert/swh/swh-environment/swh-counters/swh/counters/cli.py", line 80, in journal_client
client = KeyOrientedJournalClient(**journal_cfg)
File "/home/anlambert/swh/swh-environment/swh-journal/swh/journal/client.py", line 217, in __init__
for topic in self.consumer.list_topics(timeout=10).topics.keys()
cimpl.KafkaException: KafkaError{code=_TRANSPORT,val=-195,str="Failed to get metadata: Local: Broker transport failure"}