projects
/
osm
/
MON.git
/ blobdiff
commit
grep
author
committer
pickaxe
?
search:
re
summary
|
shortlog
|
log
|
commit
|
commitdiff
|
tree
raw
| inline |
side by side
Removes threading from common_consumer
[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
..
363b9fc
100644
(file)
--- a/
osm_mon/core/message_bus/consumer.py
+++ b/
osm_mon/core/message_bus/consumer.py
@@
-10,6
+10,4
@@
class Consumer(KafkaConsumer):
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)
+ group_id=group_id)