Re: Flink_Kafka

2016-02-04 Thread Robert Metzger
Hi, I don't understand what you are trying to achieve. If you want to read the topic from the beginning, use a different group.id. Flink should consume data from the topic when you produce something into it. As you can see from the log statement, its at the "INFO" log level, hence its not an issue

Flink_Kafka

2016-02-04 Thread Vinaya M S
Hi, I'm new to Flink. I was working with Flink and Kafka before. It was working fine. But now Flink is not able to consume data from Kafka even with newly created topic. This is the log: 15:12:59,684 INFO org.apache.flink.streaming.connectors.kafka.FlinkKafkaConsumer - No prior offsets found f