Changeset View
Changeset View
Standalone View
Standalone View
swh/journal/tests/test_client.py
Show All 28 Lines | REV = { | ||||
}, | }, | ||||
"type": "git", | "type": "git", | ||||
"directory": ( | "directory": ( | ||||
b"\x00\x00\x00\x00\x00\x00\x00\x00\x00\x00\x00\x00\x00\x00\x00" | b"\x00\x00\x00\x00\x00\x00\x00\x00\x00\x00\x00\x00\x00\x00\x00" | ||||
b"\x01\x02\x03\x04\x05" | b"\x01\x02\x03\x04\x05" | ||||
), | ), | ||||
"synthetic": False, | "synthetic": False, | ||||
"metadata": None, | "metadata": None, | ||||
"parents": (), | "parents": [], | ||||
"id": b"\x8b\xeb\xd1\x9d\x07\xe2\x1e0\xe2 \x91X\x8d\xbd\x1c\xa8\x86\xdeB\x0c", | "id": b"\x8b\xeb\xd1\x9d\x07\xe2\x1e0\xe2 \x91X\x8d\xbd\x1c\xa8\x86\xdeB\x0c", | ||||
} | } | ||||
def test_client(kafka_prefix: str, kafka_consumer_group: str, kafka_server: str): | def test_client(kafka_prefix: str, kafka_consumer_group: str, kafka_server: str): | ||||
producer = Producer( | producer = Producer( | ||||
{ | { | ||||
"bootstrap.servers": kafka_server, | "bootstrap.servers": kafka_server, | ||||
▲ Show 20 Lines • Show All 284 Lines • Show Last 20 Lines |