Adds max_poll_interval_ms=900000 in KafkaConsumer
Signed-off-by: Benjamin Diaz <bdiaz@whitestack.com>
import json
import logging
import sys
import json
import logging
import sys
from json import JSONDecodeError
import six
from json import JSONDecodeError
import six
log.exception("Exception: ")
return
retries = retries + 1
log.exception("Exception: ")
return
retries = retries + 1
log.info("Listening for messages...")
for message in common_consumer:
log.info("Listening for messages...")
for message in common_consumer:
super().__init__(bootstrap_servers=cfg.BROKER_URI,
key_deserializer=bytes.decode,
value_deserializer=bytes.decode,
super().__init__(bootstrap_servers=cfg.BROKER_URI,
key_deserializer=bytes.decode,
value_deserializer=bytes.decode,
+ max_poll_interval_ms=900000,