1 from kafka
import KafkaConsumer
3 from osm_mon
.core
.settings
import Config
6 # noinspection PyAbstractClass
7 class Consumer(KafkaConsumer
):
8 def __init__(self
, group_id
, **kwargs
):
9 cfg
= Config
.instance()
10 super().__init
__(bootstrap_servers
=cfg
.BROKER_URI
,
11 key_deserializer
=bytes
.decode
,
12 value_deserializer
=bytes
.decode
,
13 max_poll_interval_ms
=180000,