363b9fc7fb0a5bb6b13afeba51fc3296aae07088
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
):
9 cfg
= Config
.instance()
10 super().__init
__(bootstrap_servers
=cfg
.BROKER_URI
,
11 key_deserializer
=bytes
.decode
,
12 value_deserializer
=bytes
.decode
,