Changeset View

Standalone View

Show First 20 Lines • Show All 249 Lines • ▼ Show 20 Lines	) -> Consumer:
] + [		] + [
f"{prefix}_privileged.{object_type}"		f"{prefix}_privileged.{object_type}"
for object_type in test_config["privileged_object_types"]		for object_type in test_config["privileged_object_types"]
]		]
consumer.subscribe(kafka_topics)		consumer.subscribe(kafka_topics)

yield consumer		yield consumer

		consumer.commit()
consumer.close()		consumer.close()