Kafka Consumer 如何（应该）应对有毒消息

Question

当 Kafka 消费者无法反序列化消息时，客户端应用程序是否有责任处理中毒消息？

或

Kafka "increment" 消息是否偏移并继续消费有效消息？

是否有 "Best Practice" 用于处理 Kafka 主题上持有的毒消息？

Answer 1

当 Kafka 无法反序列化记录时，消费者将收到 org.apache.kafka.common.KafkaException，您应该自己提交偏移量并继续消费。