[
https://issues.apache.org/jira/browse/FLINK-3326?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15130590#comment-15130590
]
Farouk Salem commented on FLINK-3326:
-------------------------------------
Thanks for your super fast replies. Regarding using checkpointing, it doesn't
matter because I tried both scenarios and the same problem happened.
Yes, i use the same group id for both jobs! Now I realized that this could be
the problem
> 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)
