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-512', '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 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"}