Kafka Newbie question

2016-04-08 Thread Pradeep Bhattiprolu
Hi All I am a newbie to kafka. I am using the new Consumer API in a thread acting as a consumer for a topic in Kafka. For my testing and other purposes I have read the queue multiple times using console-consumer.sh script of kafka. To start reading the message from the beginning in my java code ,

Re: Kafka Newbie question

2016-04-09 Thread Pradeep Bhattiprolu
ffset in Kafka or if the current > offset does not exist any more on the server (e.g. because that data has > been deleted). In case that auto commit is enabled, the committed offset is > available in some servers. > > Thanks, > Liquan > > On Fri, Apr 8, 2016 at 10:44 PM

Re: Kafka Newbie question

2016-04-12 Thread Pradeep Bhattiprolu
2016 at 12:21 AM, Harsha wrote: > > > Pradeep, > > How about > > > > > https://kafka.apache.org/090/javadoc/org/apache/kafka/clients/consumer/KafkaConsumer.html#seekToBeginning%28org.apache.kafka.common.TopicPartition...%29 > > > > -Harsha > > &g