微信公众号搜"智元新知"关注
微信扫一扫可直接关注哦!

去丝化异常 Spring Kafka |每次使用 ErrorDeserialiser 重新启动服务器时,都会记录损坏的消息

如何解决去丝化异常 Spring Kafka |每次使用 ErrorDeserialiser 重新启动服务器时,都会记录损坏的消息

我已按照以下文档 https://www.confluent.io/blog/spring-kafka-can-your-kafka-consumers-handle-a-poison-pill/ 处理反序列化异常。 它工作正常,消息被记录并向前移动,但每次我重新启动服务器时,坏消息都会再次被记录。 有没有一种方法可以在记录错误消息后跳过/确认错误消息,以便在重新启动服务器时不会再次被接收

Consumer YAML 
spring:
  kafka:
    bootstrap-servers: localhost:9092
    consumer:
      # Configures the Spring Kafka ErrorHandlingDeserializer that delegates to the 'real' deserializers
      key-deserializer: org.springframework.kafka.support.serializer.ErrorHandlingDeserializer
      value-deserializer: org.springframework.kafka.support.serializer.ErrorHandlingDeserializer
    properties:
      # Delegate deserializers
      spring.deserializer.key.delegate.class: org.apache.kafka.common.serialization.StringDeserializer
      spring.deserializer.value.delegate.class: org.sprngframework.kafka.support.serializer.JsonDeserializer

另外,注意:= 从上面,在日志中,我看到它给出了一个警告,即 spring.deserializer.value.delegate.class 已给出 -> 但不是已知的配置。

也配置了这个

@Bean
@Configuration
@EnableKafka
public class KafkaConfiguration {

  /**
   * Boot will autowire this into the container factory.
   */
  @Bean
  public LoggingErrorHandler errorHandler() {
    return new LoggingErrorHandler();
  }
}

有人可以请教一下

版权声明:本文内容由互联网用户自发贡献,该文观点与技术仅代表作者本人。本站仅提供信息存储空间服务,不拥有所有权,不承担相关法律责任。如发现本站有涉嫌侵权/违法违规的内容, 请发送邮件至 dio@foxmail.com 举报,一经查实,本站将立刻删除。