sudufly opened a new issue, #2594: URL: https://github.com/apache/incubator-seatunnel/issues/2594
### Search before asking - [X] I had searched in the [issues](https://github.com/apache/incubator-seatunnel/issues?q=is%3Aissue+label%3A%22bug%22) and found no similar issues. ### What happened spark-streaming 偏移量提交异常，任务未处理完，但是偏移量已经提交  上述提交偏移量部分可简化为下图  任务还未完成，但是offsetRanges 会一直被更新为最新的偏移量，不知道是不是我理解不深刻0.0 ### SeaTunnel Version apache-seatunnel-incubating-2.1.0 ### SeaTunnel Config ```conf source { kafkaStream { topics = "seatunnel_input" consumer.bootstrap.servers = "cat-1-200:9092" consumer.group.id = "seatunnel_group" result_table_name = "msg" } kafkaStream { topics = "accessdata-test" consumer.bootstrap.servers = "cat-1-200:9092" consumer.group.id = "seatunnel_group" result_table_name = "msg-1" } } ``` ### Running Command ```shell ./bin/start-seatunnel-spark.sh --master local[4] --deploy-mode client -c json ``` ### Error Exception ```log xxx ``` ### Flink or Spark Version _No response_ ### Java or Scala Version _No response_ ### 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](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]
