| commit | 8280121bd3684354e83cd43eb91ad616405e2e8d | [log] [tgz] |
|---|---|---|
| author | Benjamin Diaz <bdiaz@whitestack.com> | Wed Oct 17 12:45:02 2018 -0300 |
| committer | Benjamin Diaz <bdiaz@whitestack.com> | Wed Oct 17 12:45:02 2018 -0300 |
| tree | 8b541f84f0d49805127882b811aa3e90060b3a0b | |
| parent | 93699898c51364cde193d8d441f4aed45670e7bf [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>