Closed katreniak closed 8 months ago
Steps to reproduce the problem:
setDefaultConsumeTimeout(1000)
consumer.consume(128, cb)
Actual outcome:
Expected outcome:
KafkaConsumerConsumeNum call underlaying c++ m_consumer->Consume in cycle until
m_consumer->Consume
KafkaConsumerConsumeNum must enforce its timeout over all m_consumer->Consume invocations altogether.
Closing in favour of https://github.com/Blizzard/node-rdkafka/pull/1053
Steps to reproduce the problem:
setDefaultConsumeTimeout(1000)
consumer.consume(128, cb)
Actual outcome:
Expected outcome:
KafkaConsumerConsumeNum call underlaying c++
m_consumer->Consume
in cycle untilKafkaConsumerConsumeNum must enforce its timeout over all
m_consumer->Consume
invocations altogether.