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

["Gyula Fora (JIRA)" <ji...@apache.org>]

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)