You are viewing a plain text version of this content. The canonical link for it is here.
Posted to user@storm.apache.org by Anis Nasir <aa...@gmail.com> on 2014/05/29 14:11:55 UTC

Unable to read from beginning of the topic storm-kafka-0.8-plus

Dear all,

I am using Storm 0.9.1-incubating, along with kafka 0.8.1.1 with
storm-kafka-0.8-plus. Initially, the library worked fine and was able to
fetch messages from a kafka topic. However, after running the topology few
times, now I am unable to fetch any message from the kafka topic. I believe
it is a problem to set the offset from the beginning of the topic. I have
tried setting

kafkaConfig.startOffsetTime = -2;
and also
kafkaConfig.forceFromStart = true;

However, none of these parameters force the spout to read the messages from
beginning of the topic. I would really appreciate any help in this regard.

Regards

Anis