在我的结构化流应用程序中，我从mq读取数据，并进行一些转换，然后将结果写入 kafka . 我已经实现了mq自定义源代码。
我的问题是，如果在转换过程中或在将消息写入kafka时出现异常，如何将消息回滚到mq。
我阅读的消息作为批量，说每批5000条消息，但在写的结果，如果 kafka 向下，我们有什么方法可以回滚消息？
在使用自定义源（任何非分布式源，如mq）时，是否有任何方法可以回滚或恢复消息。