Hi ,

i have a topology where i am emmitting json objects onto a kafka topic
using a kafka producer to a storm bolt.
I have been relaying the same objects on the same topic over and over again
as i am figuring out few things.
after a while i can see that if i use kafkaConfig.forceFromStart=true; then
i can see the messages on the topic from start to the recent most offset
value, however , whenever i use kafkaConfig.forceFromStart=false; , my bolt
does not receive any data .
Is this normal behaviour or am i missing something.
Also, is it wise to use Zookeeper 3.4.6 along with kafka 2.10_8.1.1 . . and
storm 0.9.2_incubating which supports the kafka spout.
Also in the above topology i am using kafka spout for ingesting data into
storm.

Thanks,
Siddharth Ubale

Reply via email to