diff --git a/swh/journal/client.py b/swh/journal/client.py --- a/swh/journal/client.py +++ b/swh/journal/client.py @@ -62,12 +62,6 @@ 'Option \'auto_offset_reset\' only accept %s.' % ACCEPTED_OFFSET_RESET) - for object_type in object_types: - if object_type not in ACCEPTED_OBJECT_TYPES: - raise ValueError( - 'Option \'object_types\' only accepts %s.' % - ACCEPTED_OFFSET_RESET) - self.consumer = KafkaConsumer( bootstrap_servers=brokers, key_deserializer=kafka_to_key,