Kafka 中的错误 JSON - Spring Cloud Stream Kafka Binder

Question

因此，有时在我的 StreamListener 的 Kafka 消息中存在无效的 JSON 条目。 JSON 解析器当然会抛出一个错误，这很好。但是，我正在使用手动 acking，所以同样的消息再次返回并再次抛出错误，等等......有没有办法相对干净地自动 ack bad JSON？事实上，我从来没有真正收到消息，因为异常是在进入我的侦听器方法之前抛出的。

Answer 1

目前没有，但我们正在定义我们的错误处理故事 - 看起来您正在寻找的是格式错误的消息（即无法提取的消息将被忽略）的功能。

现在的替代方法是跳过框架内转换，检索 String/byte[] 有效负载并手动进行解析（这肯定不如基于框架的转换优雅）- 只是确认通知错误后格式错误的消息。