[
https://issues.apache.org/jira/browse/FLINK-3326?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15130578#comment-15130578
]
Aljoscha Krettek commented on FLINK-3326:
-----------------------------------------
What are you setting as your {{"group.id"}} in the {{Properties}} of the Kafka
consumer? If I'm not mistaken the {{"auto.offset.reset"}} value, for example
{{"smallest"}}, is only respected by Kafka if your group has not read from the
topic before.
You should be able to re-read the topic from the beginning by setting a
different {{"group.id"}} every time you read.
> Kafka Consumer doesn't retrieve messages after killing flink job which was
> using the same topic
> -----------------------------------------------------------------------------------------------
>
> Key: FLINK-3326
> URL: https://issues.apache.org/jira/browse/FLINK-3326
> Project: Flink
> Issue Type: Bug
> Components: flink-contrib
> Affects Versions: 0.10.1
> Environment: Java
> Reporter: Farouk Salem
> Priority: Blocker
> Labels: flink, kafka
>
> If there is a streaming job which retrieving data from a Kafka topic (from
> the smallest offest) and this job is killed manually, starting another job
> (or the same job) after the killed job will not be able to consume data from
> the same topic starting from smallest offset.
> I tried this behavior more than 10 times and each time, it failed
--
This message was sent by Atlassian JIRA
(v6.3.4#6332)
