LibRdKafka C++ (1.9.1 and 2.10.1) KafkaConsumer::consume method returns ERR__TIMED_OUT when there are more messages in the brokers

Clients Non-Java Clients
1

My Test:

Produce (RdKafka::Producer::produce(..)) 200 messages with payload 1Kb

In a loop (until 200 messages consumed):
KafkaConsumer::consume (timeout = 100 ms)

I hit the timeout 10 times while retrieving messages (ERR__TIMED_OUT)

If I increase the timeout to 2000 ms then I don’t hit the timeout

3

My question is:
Is this expected behaviour?

4

Which specific configuration are you experimenting with? max.poll.interval.ms?