swh_storage_backend_config = {'check_config': {'check_write': True}, 'cls': 'local', 'db': "dbname=storage user=postgres host=127.0.0.1 port=16873 ...riter': {'brokers': ['127.0.0.1:41371'], 'client_id': 'kafka_writer-1', 'cls': 'kafka', 'prefix': 'muhacqhoos-1'}, ...} kafka_prefix = 'muhacqhoos', kafka_consumer_group = 'test-consumer-muhacqhoos' kafka_server = '127.0.0.1:41371'

kafka_prefix = 'zojblblzpy', kafka_server = '127.0.0.1:41371' consumer = <cimpl.Consumer object at 0x7f56dfc3f9d8>

kafka_prefix = 'hsztdsxihy', kafka_consumer_group = 'test-consumer-hsztdsxihy' kafka_server = '127.0.0.1:41371', privileged = True

replayer_storage_and_client = (<swh.storage.in_memory.InMemoryStorage object at 0x7f56e1463630>, <swh.journal.client.JournalClient object at 0x7f56e146d128>) caplog = <_pytest.logging.LogCaptureFixture object at 0x7f56e146df28>