projects / osm / MON.git / commit
? search:
summary | shortlog | log | commit | commitdiff | tree
(parent: 9369989) | patch
Removes threading from common_consumer 13/6713/1
authorBenjamin Diaz <bdiaz@whitestack.com>
Wed, 17 Oct 2018 15:45:02 +0000 (12:45 -0300)
committerBenjamin Diaz <bdiaz@whitestack.com>
Wed, 17 Oct 2018 15:45:02 +0000 (12:45 -0300)
commit8280121bd3684354e83cd43eb91ad616405e2e8d
tree8b541f84f0d49805127882b811aa3e90060b3a0btree | snapshot
parent93699898c51364cde193d8d441f4aed45670e7bfcommit | diff
Removes threading from common_consumer

It appears KafkaConsumer is not threadsafe, and it was generating
issues regarding the sending of heartbeats, causing kafka to kill
connections and causing coordinator dead errors.
Also removes heartbeat and session timeouts from consumer config.
They were generating conflicts with different default request
timeouts, and were in place to leverage issues regarding what is
mentioned above.

Signed-off-by: Benjamin Diaz <bdiaz@whitestack.com>
osm_mon/core/message_bus/common_consumer.py diff | blob | history
osm_mon/core/message_bus/consumer.py diff | blob | history