from swh.journal.client import JournalClient
import logging

logging.basicConfig(level=logging.INFO)
logging.info('Running test')

client = JournalClient(
    **{
        'security.protocol': 'SASL_SSL',
        'sasl.mechanisms': 'SCRAM-SHA-512',
        'sasl.username': 'seirl',
        'sasl.password': 'CHANGEME',
    },

    brokers=[
        'kafka01.euwest.azure.softwareheritage.org:9093',
        'kafka02.euwest.azure.softwareheritage.org:9093',
        'kafka03.euwest.azure.softwareheritage.org:9093',
        'kafka04.euwest.azure.softwareheritage.org:9093',
        'kafka05.euwest.azure.softwareheritage.org:9093',
        'kafka06.euwest.azure.softwareheritage.org:9093',
    ],
    object_types=[
        'origin_visit',
        'snapshot',
        'release',
        'revision',
        'directory',
    ],
    group_id=('test-journal-client-broken'),
)

client.process(lambda *a, **k: None)