Page MenuHomeSoftware Heritage
Paste P594

(An Untitled Masterwork)
ActivePublic

Authored by seirl on Feb 10 2020, 6:03 PM.
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)