Hi Jayant, Can you try to connect to kafka server 0.10.x via flink-connector-kafka-0.10? See if it still throws this exception.
Thanks, vino. Jayant Ameta <wittyam...@gmail.com> 于2018年9月4日周二 下午1:20写道： > Flink: 1.4.2 > flink-connector-kafka-0.11_2.11 (1.4.2) > Kafka: 0.10.1.0 > > Jayant Ameta > > > On Tue, Sep 4, 2018 at 10:16 AM vino yang <yanghua1...@gmail.com> wrote: > >> 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/ >>>> >>>
