Kafka consumer is not reading message sent by producer if started after producer

I found property auto.offset.reset=earliest or auto.offset.reset=latest.

Now here is my scenario with 1 Topic, 1 partition,1 consumer

For example, i have started producer. Producer send 100 records to Topic. Now i start the consumer. According to the property auto.offset.reset=earliest my consumer will start reading record from 0 index of partition.

Now if my consumer does async commit for 1-100 record and goes down. Meanwhile producer send 100 records more. When consumer comes up, will it start reading message from 0 index of partition or will it start reading from 101 index of...

Read More »

By: StackOverFlow - Monday, 5 November

Related Posts