Hisoka-X commented on PR #7273: URL: https://github.com/apache/seatunnel/pull/7273#issuecomment-2255389761
> > 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 In this case, users cannot use the SeaTunnel job status to determine whether the data reading is running normally. This is unacceptable -- 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