问题描述
我无法理解如何正确处理 Spring Cloud 流中的反序列化异常。主要是因为实现的框架不支持标头，并且 DLQ 应该是与原始消息不同的模式。所以流程需要是：消费消息 -> 反序列化错误 -> DlqHandler -> 用 NEW schema 序列化 -> 发送到 DLQ
下面链接的文档并没有给出一个关于这是否可能的好主意。我已经看到了很多 Spring-Kafka 的 SeekToCurrentErrorHandler 示例，但据我所知，这些示例是不同的实现，并且与我如何正确获取反序列化错误然后有一个自定义代码部分以序列化为新格式并移动的方式不匹配从那里开始。
我的主要问题是：是否可以使用 Spring Cloud Streams (kafka) 捕获反序列化异常并重新序列化？
Spring Cloud Documentation for DLQ
解决方法
暂无找到可以解决该程序问题的有效方法，小编努力寻找整理中！
如果你已经找到好的解决方法，欢迎将解决方案带上本链接一起发送给小编。
小编邮箱:dio#foxmail.com (将#修改为@）