# noinspection PyAbstractClass
class Consumer(KafkaConsumer):
- def __init__(self, group_id):
+ def __init__(self, group_id, **kwargs):
cfg = Config.instance()
super().__init__(bootstrap_servers=cfg.BROKER_URI,
key_deserializer=bytes.decode,
value_deserializer=bytes.decode,
- group_id=group_id)
+ max_poll_interval_ms=180000,
+ group_id=group_id,
+ **kwargs)