Kafka Avro序列化程序，忽略序列化异常
org.apache.kafka.common.errors.SerializationException: Error deserializing Avro message for id 58
Caused by: java.lang.ClassCastException:
有没有一种方法让我忽略这些异常并在消费者处移动偏移量？我想，因为我使用手动偏移提交，我有这个问题。有人知道如何配置kafka-avro-serializer-6.0.0.jar来完成我想要的任务吗？
多谢了。
共有1个答案
您主要有两种选择：
- 重写反序列化程序
deserialize方法，并通过捕获ClassCastException异常并返回Null对象而不是反序列化的记录来重新实现该方法。然后，这些null对象将在您的使用者代码中处理。 - 捕获使用者代码上的
SerializationException异常，并Seek使用者通过错误记录偏移量。
Jon Boulineau的这篇文章很好地解释了这两种解决方案。
-
问题内容： 我使用以下代码来序列化从外部服务获得的响应，并作为我的服务的一部分返回json响应。但是，当外部服务返回带有时区（10：30：00.000-05.00）的时间值时，杰克逊会将其转换为15:30:00。如何忽略时区值？ 问题答案： 您可以创建自定义解串器 告诉杰克逊使用您的自定义解串器 并像这样使用它： 您可以使用Jackson自定义序列化为服务响应添加时区信息
-
我有一个这样的对象： 我是否可以使用和我的条件来仅在不为负数的情况下包含该值？或者有没有其他的解决办法我可以做到这一点？
-
问题内容： 我有一个简单的接口与属性的getter和setter。 我还有另一个实现此接口的UserAccount类。 我的问题是我想序列化money属性，但在反序列化它时忽略它，即，不接受用户对此属性的任何值。我在setter上尝试过@JsonIgnore，在getter上尝试过@JsonIgnore（false），它确实会忽略它，但是在序列化它时也会这样做。 我在setter上尝试了@Json
-
在这种情况下，如果验证失败，我希望将请求返回给用户，并附上相应的错误消息。我遇到的问题是，我使用Jackson处理JSON请求，验证失败也会导致Jackson无法序列化消息。 例如，如果我有此对象： ...当我去序列化时，字段无效（假设它有11个字符）... ...我得到了一个JsonProcessingException（错误验证对象）。我已经确认一个有效的对象序列化没有问题。所以我的问题是：我
-
我有另一个类UserAccount实现了这个接口。 我的问题是，我想序列化money属性，但在反序列化时忽略它，即不接受用户对该属性的任何值。我在setter上尝试了@jsonIgnore,在getter上尝试了@jsonIgnore（false）,它确实忽略了它,但是它在序列化它的同时也忽略了它。 我在setter上尝试了@jsonIgnore,在getter上尝试了@jsonProperty,
-
首先，我在这个网站上读了一些其他的答案，还有一些关于jackson序列化的答案，但它们都提供了忽略字段的方法。但是，在Java中，不能为。