flink-user mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From Vinaya M S <vinay...@gmail.com>
Subject Flink_Kafka
Date Thu, 04 Feb 2016 20:22:39 GMT

I'm new to Flink. I was working with Flink and Kafka before. It was working
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 for some partitions in topic KafkaTweet. Fetched the
following start offsets [FetchPartition {partition=0, offset=3061}]

I'm using Flink: 0.10.1 and Kafka:8.2.2 and flink-connector-kafka 10.1.

*Any help would be much appreciated.*

*Thank you,*


View raw message