Hi,

I am running kafka 0.9.0 locally.

I am having a particular situation in the following scenario.

(1) 1 Producer inserts 500 records (300bytes each aprox) to 1 topic 0
partition (or 1 as you prefer)
(2) After the producer finished inserting the 500 records, 1 Consumer reads
in a loop from this topic with consumer.poll(0)
and max.partition.fetch.bytes=500, sometimes that call brings records and
something the loop has to go over a few times until it brings something.
Can someone explain me why it doesn't fetch a record each time that it
polls? can a poll operation affect another poll operation?
why if I've inserted 500 records I have to poll more than 500 times?

I have tried using poll(0), because in the documentation it says, "if 0,
returns with any records that are available now".

Thanks

Reply via email to