Changeset View
Changeset View
Standalone View
Standalone View
swh/objstorage/replayer/tests/test_replay.py
| Show First 20 Lines • Show All 44 Lines • ▼ Show 20 Lines | writer = get_journal_writer( | ||||
| cls="kafka", | cls="kafka", | ||||
| brokers=[kafka_server], | brokers=[kafka_server], | ||||
| client_id="kafka_writer", | client_id="kafka_writer", | ||||
| prefix=kafka_prefix, | prefix=kafka_prefix, | ||||
| anonymize=False, | anonymize=False, | ||||
| ) | ) | ||||
| for content in CONTENTS: | for content in CONTENTS: | ||||
| objstorage1.add(content.data) | objstorage1.add(content.data, obj_id=content.sha1) | ||||
| writer.write_addition("content", content) | writer.write_addition("content", content) | ||||
| replayer = JournalClient( | replayer = JournalClient( | ||||
| brokers=kafka_server, | brokers=kafka_server, | ||||
| group_id=kafka_consumer_group, | group_id=kafka_consumer_group, | ||||
| prefix=kafka_prefix, | prefix=kafka_prefix, | ||||
| stop_on_eof=True, | stop_on_eof=True, | ||||
| # stop_after_objects=len(objects), | # stop_after_objects=len(objects), | ||||
| Show All 12 Lines | |||||