search

silviucpp / erlkaf

Erlang kafka driver based on librdkafka
MIT License
83 stars 41 forks source link

Fix for long running messages #30

Closed silviucpp closed 3 years ago

silviucpp commented 3 years ago

Make sure *_poll on the main queue/consumer queue is called at least once in the max.poll.interval.ms interval

silviucpp commented 3 years ago

Fix based on the discussion with librdkafka author https://github.com/edenhill/librdkafka/issues/3300