[Bug] [Connector Kafka] Kafka consumer stop fetching after TM node restarted

[litiliu]

Search before asking

• [X] I had searched in the issues and found no similar issues.

What happened

I'm run a seatunnel job with the Kafka connector on the Flink engine on the remote flink cluster, after the TM encountered a runtime exception, that job entered the restart mechanism(fixed-day 1s). After Flink's restart mechanism restored that job, we found the Kafka connector stopped ingesting any data.

SeaTunnel Version

2.3.5

SeaTunnel Config

none

Running Command

none

Error Exception

none

Zeta or Flink or Spark Version

flink 1.15.4

Java or Scala Version

java 1.8

Screenshots

No response

Are you willing to submit PR?

• [X] Yes I am willing to submit a PR!

Code of Conduct

• [X] I agree to follow this project's Code of Conduct