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
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 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,*

*Vinaya*

Mime
View raw message