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

WillLiaowh
  • 32

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

回复
阅读 340
1 个回答

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

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

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

你知道吗?

宣传栏