diff --git a/swh/journal/client.py b/swh/journal/client.py --- a/swh/journal/client.py +++ b/swh/journal/client.py @@ -88,6 +88,10 @@ if isinstance(brokers, str): brokers = [brokers] + debug_logging = rdkafka_logger.isEnabledFor(logging.DEBUG) + if debug_logging and 'debug' not in kwargs: + kwargs['debug'] = 'consumer' + consumer_settings = { **kwargs, 'bootstrap.servers': ','.join(brokers),