Changeset View

Standalone View

				# Copyright (C) 2021 The Software Heritage developers
				# See the AUTHORS file at the top-level directory of this distribution
				# License: GNU General Public License version 3, or any later version
				# See top-level LICENSE file for more information

				import logging

				import pytest

				logger = logging.getLogger(__name__)


				JOURNAL_OBJECTS_CONFIG_TEMPLATE = """
				journal:
				brokers:
				- {broker}
				prefix: {prefix}
				group_id: {group_id}
				"""


				@pytest.fixture
				def journal_config(kafka_server, kafka_prefix) -> str:
				return JOURNAL_OBJECTS_CONFIG_TEMPLATE.format(
				broker=kafka_server, group_id="test-consumer", prefix=kafka_prefix
				)