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