projects
/
osm
/
MON.git
/ blobdiff
commit
grep
author
committer
pickaxe
?
search:
re
summary
|
shortlog
|
log
|
commit
|
commitdiff
|
tree
raw
|
inline
| side by side
"Increases delta of start_time when collecting OpenStack metrics"
[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
1ccf936
..
c0a9dd0
100644
(file)
--- a/
osm_mon/core/message_bus/consumer.py
+++ b/
osm_mon/core/message_bus/consumer.py
@@
-10,6
+10,6
@@
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,
- max_poll_interval_ms=
90
0000,
+ max_poll_interval_ms=
18
0000,
group_id=group_id,
**kwargs)
group_id=group_id,
**kwargs)