osm_mon/core/message_bus/consumer.py

   1 from kafka import KafkaConsumer
   2
   3 from osm_mon.core.settings import Config
   4
   5
   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,
  14                          group_id=group_id,
  15                          **kwargs)