Changeset View
Changeset View
Standalone View
Standalone View
swh/journal/tests/test_replay.py
| Show All 39 Lines | def test_storage_play( | ||||
| (_, port) = kafka_server | (_, port) = kafka_server | ||||
| kafka_prefix += '.swh.journal.objects' | kafka_prefix += '.swh.journal.objects' | ||||
| storage = get_storage(**storage_config) | storage = get_storage(**storage_config) | ||||
| producer = Producer({ | producer = Producer({ | ||||
| 'bootstrap.servers': 'localhost:{}'.format(port), | 'bootstrap.servers': 'localhost:{}'.format(port), | ||||
| 'client.id': 'test producer', | 'client.id': 'test producer', | ||||
| 'enable.idempotence': 'true', | 'acks': 'all', | ||||
| }) | }) | ||||
| now = datetime.datetime.now(tz=datetime.timezone.utc) | now = datetime.datetime.now(tz=datetime.timezone.utc) | ||||
| # Fill Kafka | # Fill Kafka | ||||
| nb_sent = 0 | nb_sent = 0 | ||||
| nb_visits = 0 | nb_visits = 0 | ||||
| for (object_type, (_, objects)) in OBJECT_TYPE_KEYS.items(): | for (object_type, (_, objects)) in OBJECT_TYPE_KEYS.items(): | ||||
| ▲ Show 20 Lines • Show All 188 Lines • Show Last 20 Lines | |||||