Hi Harsha, This is my config
SpoutConfig config = new SpoutConfig(brokerHosts, "CNTopic", "/1", "KafkaSpout"); storm.kafka.KafkaSpout spout = new storm.kafka.KafkaSpout(config); Thanks Pranesh On Thu, Mar 12, 2015 at 4:43 PM, Harsha <[email protected]> wrote: > Hi Pranesh, > Can you share your spoutconfig for kafka spout. > -Harsha > > > On March 12, 2015 at 11:58:29 AM, Pranesh Radhakrishnan ( > [email protected]) wrote: > > I am new to Kafka and Storm. I have done simple program to post some > messages to Kafka broker and able to read the messages using kafkaStorm > consumer. > Now i have stopped the Kafkastorm consumer and post one message to kafka > broker and the message offset was 50, and then i restarted the consumer, > my expectation was the consumer should read the message from offset 50 but > it reads the message from offset 51. > > Can anyone help me to fix this. > > Regards > Pranesh > >
