(An Untitled Masterwork)
ActivePublic
Actions

Authored by seirl on Feb 10 2020, 6:03 PM.

Tags

None

Subscribers

None

	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)

(An Untitled Masterwork)ActivePublicActions