D2280.id7846.diff
No OneTemporary
Actions

Size

836 B

Subscribers

None

D2280.id7846.diff
View Options

	diff --git a/swh/journal/client.py b/swh/journal/client.py
	--- a/swh/journal/client.py
	+++ b/swh/journal/client.py
	@@ -13,6 +13,7 @@
	from swh.journal import DEFAULT_PREFIX

	logger = logging.getLogger(__name__)
	+rdkafka_logger = logging.getLogger(__name__ + '.rdkafka')


	# Only accepted offset reset policy accepted
	@@ -95,12 +96,12 @@
	'on_commit': _on_commit,
	'error_cb': _error_cb,
	'enable.auto.commit': False,
	- 'logger': logger,
	+ 'logger': rdkafka_logger,
	}

	logger.debug('Consumer settings: %s', consumer_settings)

	- self.consumer = Consumer(consumer_settings, logger=logger)
	+ self.consumer = Consumer(consumer_settings)

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