lightzhao commented on PR #7273: URL: https://github.com/apache/seatunnel/pull/7273#issuecomment-2255319232
> If we modify the logic like this, is it possible that the Kafka cluster is abnormal, but SeaTunnel cannot exit normally? Yes, the expectation is that the consumer thread will not exit after the Kafka cluster fails, and continue to execute after recovery, otherwise all tasks will need to be restarted -- This is an automated message from the Apache Git Service. To respond to the message, please log on to GitHub and use the URL above to go to the specific comment. To unsubscribe, e-mail: commits-unsubscr...@seatunnel.apache.org For queries about this service, please contact Infrastructure at: us...@infra.apache.org