flink-dev mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From "Farouk Salem (JIRA)" <j...@apache.org>
Subject [jira] [Created] (FLINK-3326) Kafka Consumer doesn't retrieve messages after killing flink job which was using the same topic
Date Wed, 03 Feb 2016 15:36:39 GMT
Farouk Salem created FLINK-3326:
-----------------------------------

             Summary: 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


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)

Mime
View raw message