Hi All, We're seeing errors on the Flink Task Manager when trying to consume from Kafka:

2023-02-01 03:48:41,522 ERROR org.apache.kafka.common.metrics.Metrics                      [] - Error when removing metric from org.apache.kafka.common.metrics.JmxReporter
2023-02-01 03:45:28,083 ERROR org.apache.flink.runtime.io.network.netty.PartitionRequestQueue [] - Encountered error while consuming partitions

Any inputs on why this happens? I believe the JobManager restarts at the same time.

2023-02-01 03:50:41,399 ERROR org.apache.flink.runtime.taskexecutor.DefaultJobLeaderService [] - Registration at JobManager failed due to an error

Any thoughts are appreciated, thanks!