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
