[jira] [Created] (FLINK-6262) UnknownTopicOrPartitionException Kafka consumer error on broker restart/failure

[Gyula Fora (JIRA)]

Gyula Fora created FLINK-6262:
---------------------------------

             Summary: UnknownTopicOrPartitionException Kafka consumer error on 
broker restart/failure
                 Key: FLINK-6262
                 URL: https://issues.apache.org/jira/browse/FLINK-6262
             Project: Flink
          Issue Type: Bug
          Components: Kafka Connector
    Affects Versions: 1.1.4, 1.2.0
            Reporter: Gyula Fora


The Kafka consumer fails on broker restarts/failures with the following error:

java.io.IOException: Error while fetching from broker 'Node(22, 
kafka22.sto.midasplayer.com, 9092)': 
Exception for event.bifrost.log:10: 
kafka.common.UnknownTopicOrPartitionException
        at sun.reflect.GeneratedConstructorAccessor35.newInstance(Unknown 
Source)
        at 
sun.reflect.DelegatingConstructorAccessorImpl.newInstance(DelegatingConstructorAccessorImpl.java:45)
        at java.lang.reflect.Constructor.newInstance(Constructor.java:422)
        at java.lang.Class.newInstance(Class.java:442)
        at kafka.common.ErrorMapping$.exceptionFor(ErrorMapping.scala:86)
        at kafka.common.ErrorMapping.exceptionFor(ErrorMapping.scala)
        at 
org.apache.flink.streaming.connectors.kafka.internals.SimpleConsumerThread.run(SimpleConsumerThread.java:292)

        at 
org.apache.flink.streaming.connectors.kafka.internals.SimpleConsumerThread.run(SimpleConsumerThread.java:313)

We should have some restart logic around this



--
This message was sent by Atlassian JIRA
(v6.3.15#6346)