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 | |||||