关于Kafka重试达到次数之后的处理方案

Question

关于Kafka的重试机制，我了解的是生产者发消息到broker的时候有retries这个属性，代表发生异常的时候生产者发消息的重试次数，如果达到重试次数，生产者就放弃重试并返回异常，那么这个时候后续该怎么处理这个消息或者这个异常呢？
另外消费者是否也有重试的机制呢？比如消费者消费消息的时候有异常也会重试吗？

Answer 1

不是已经回答过你一次了吗，当重试次数超过预设的阈值后，需要怎么处理是由你自己的业务场景决定。常见的做法包括

• 继续重试直到天荒地老，如果是网线断了这种方法非常低效。
• 如果业务对丢失消息不敏感，可以直接抛弃这条信息
• 如果业务对丢消息敏感，可以把错误记录下来，然后告警让人工介入处理

总之怎么处理是由你的业务决定，消费者也一样。