Hi Jayant, Can you provide more specific information? For example, the version of your Flink, the version of kafka on which Flink-Kafka-Connector depends, and the version of kafka server.
Thanks, vino. Jayant Ameta <wittyam...@gmail.com> 于2018年9月4日周二 下午12:32写道： > I am getting the same error. Is there a way to retry/ignore instead of > killing the job? > > Jayant Ameta > > > On Tue, May 22, 2018 at 7:58 PM gerardg <ger...@talaia.io> wrote: > >> 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/ >> >
