[ https://issues.apache.org/jira/browse/KAFKA-1808?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ]
Jay Kreps resolved KAFKA-1808. ------------------------------ Resolution: Invalid > SimpleConsumer not working as expected > -------------------------------------- > > Key: KAFKA-1808 > URL: https://issues.apache.org/jira/browse/KAFKA-1808 > Project: Kafka > Issue Type: Bug > Components: consumer > Affects Versions: 0.8.1.1 > Environment: linux_x64 > Reporter: ajay > Assignee: Neha Narkhede > Original Estimate: 24h > Remaining Estimate: 24h > > I followed following link > https://cwiki.apache.org/confluence/display/KAFKA/0.8.0+SimpleConsumer+Example > The consumers are consuming messages from a specific partition. But the issue > is that when my consumer is running and I push messages to a specif partition > of a topic using a producer it consumes messages from that partition. > But if my consumer is not running at present and I push some messages to the > topic and again start the consumer it do not consume the messages which were > pushed by the producer but again it is ready to consume messages which will > be pushed now. > I am using LatestTime() instead of EarliestTime() as I want to consume only > unprocessed messages. > For example: > Case -1 > Consumer is running : > Producer pushed M1, M2, M3 message to partition 1 of topic 1 > result: consumer will consume all three messages. > Case - 2 > Consumer is not running > producer now pushes m4, m5 m6 messgae to partition 1 of topic 1 > consumer is invoked now > result : consumer do not consume messages m4, m5, m6. > But If I check the offset then it is set to 7. This means the producer has > advanced the offset to 7 while producing messages as a result the consumer > will consume messages from offset 7 now i.e. the consumer will not consume > messages m4,m5,m6. > Please help ideally when when consumer comes up again it should read messages > from m4. SimpleConsumer should have started reading messages from the point > where he has left last time once it comes up again. > I might have filed it in a wrong category as bug, but need help to just > consume unprocessed messages only. Please help with -- This message was sent by Atlassian JIRA (v6.3.4#6332)