sj15600520109 opened a new issue, #7971: URL: https://github.com/apache/seatunnel/issues/7971
### Search before asking - [X] I had searched in the [feature](https://github.com/apache/seatunnel/issues?q=is%3Aissue+label%3A%22Feature%22) and found no similar feature requirement. ### Description 创建了一个job，设置为流处理模式，kafka-source设置为group-offset模式，首次会把当前topic里未消费的message进行消费，消费完成后，我通过生产者又生产了消息，但此时job状态一直为running状态，但不会消费消息了，是设置的问题吗？ ### Usage Scenario _No response_ ### Related issues _No response_ ### Are you willing to submit a PR? - [ ] Yes I am willing to submit a PR! ### Code of Conduct - [X] I agree to follow this project's [Code of Conduct](https://www.apache.org/foundation/policies/conduct) -- 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: [email protected] For queries about this service, please contact Infrastructure at: [email protected]
