Changeset View

Standalone View

Show First 20 Lines • Show All 226 Lines • ▼ Show 20 Lines	) -> Consumer:

kafka_topics = [		kafka_topics = [
'%s.%s' % (test_config['prefix'], object_type)		'%s.%s' % (test_config['prefix'], object_type)
for object_type in test_config['object_types']		for object_type in test_config['object_types']
]		]

consumer.subscribe(kafka_topics)		consumer.subscribe(kafka_topics)

return consumer		yield consumer

		consumer.close()