Blizzard / node-rdkafka

Node.js bindings for librdkafka
MIT License
2.08k stars 391 forks source link

consumer: fix consumeNum to respect consume timeout #1053

Open katreniak opened 8 months ago

katreniak commented 8 months ago

Steps to reproduce the problem:

Actual outcome:

Expected outcome:

KafkaConsumerConsumeNum call underlaying c++ m_consumer->Consume in cycle until

KafkaConsumerConsumeNum must enforce its timeout over all m_consumer->Consume invocations altogether.