projects
/
osm
/
MON.git
/ blobdiff
commit
grep
author
committer
pickaxe
?
search:
re
summary
|
shortlog
|
log
|
commit
|
commitdiff
|
tree
raw
|
inline
| side by side
Adds time.sleep in Kafka validation loop
[osm/MON.git]
/
osm_mon
/
core
/
message_bus
/
consumer.py
diff --git
a/osm_mon/core/message_bus/consumer.py
b/osm_mon/core/message_bus/consumer.py
index
b12cd88
..
7936513
100644
(file)
--- a/
osm_mon/core/message_bus/consumer.py
+++ b/
osm_mon/core/message_bus/consumer.py
@@
-10,6
+10,5
@@
class Consumer(KafkaConsumer):
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,
- group_id=group_id,
- session_timeout_ms=60000,
- heartbeat_interval_ms=20000)
+ max_poll_interval_ms=900000,
+ group_id=group_id)