补充两个：

1、消费者消费数据的时候，如果本条数据消费完，处理结果丢失了或offset未来得及提交，或数据库表主键id对应的值没有修改为已消费的状态，如何回滚重新处理？

2、spark部署的方式standalone和sparkOnyarn的时候有什么区别？