[
https://issues.apache.org/jira/browse/FLINK-6262?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Gyula Fora closed FLINK-6262.
-----------------------------
Resolution: Won't Fix
> 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: Connectors / Kafka
> Affects Versions: 1.1.4, 1.2.0
> Reporter: Gyula Fora
> Priority: Major
>
> 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
(v8.3.2#803003)
