背景 kafka没有重试机制不支持消息重试,也没有死信队列,因此使用kafka做消息队列时,如果遇到了消息在业务处理时出现异常,就会很难进行下一步处理。应对这种场景,需要自己实现消息重试的功能。 如果不想自己实现消息重试机制,建议使用RocketMQ作…
背景 kafka没有重试机制不支持消息重试,也没有死信队列,因此使用kafka做消息队列时,如果遇到了消息在业务处理时出现异常,就会很难进行下一步处理。应对这种场景,需要自己实现消息重试的功能。 如果不想自己实现消息重试机制,建议使用RocketMQ作…
讨论
登录后参与讨论
还没有评论,来说第一句吧。