diff --git a/swh/journal/client.py b/swh/journal/client.py --- a/swh/journal/client.py +++ b/swh/journal/client.py @@ -95,7 +95,7 @@ for object_type in object_types] logger.debug('Upstream topics: %s', - self.consumer.list_topics(timeout=1)) + self.consumer.list_topics(timeout=10)) logger.debug('Subscribing to: %s', topics) self.consumer.subscribe(topics=topics)