Hi, This consumer should not be used. This only occurs in really old and no longer supported Flink versions. You should really upgrade to a newer version of Flink and use the KafkaSource.
Best regards, Martijn On Fri, Jun 9, 2023 at 11:05 AM Anirban Dutta Gupta < anir...@indicussoftware.com> wrote: > Hello, > > We are using "FlinkKafkaConsumer011" as a Kafka source consumer for > Flink. Please guide on how to implement error handling mechanism for the > following: > 1. If the subscription to the Kafka topic gets lost, Kafka connection > gets disconnected. > In this case, is there any mechanism of re-subscribing to the Kafka > topic automatically in the program. > > 2. If there is any error in the FetchRecords of the consumer. > > Thanks and Regards, > Anirban >
