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/ >>> >>
