I've seen the same error while upgrading Kafka. We are using FlinkKafkaProducer011 and Kafka version 1.0.0. While upgrading to Kafka 1.1.0, each time a server was restarted, an already running Flink job failed with the same message.
Gerard -- Sent from: http://apache-flink-user-mailing-list-archive.2336050.n4.nabble.com/
