我有一个用例,我从队列中消耗某些日志并使用该日志中的一些信息命中某些第三方API,以防第三方系统没有正确响应我希望为该特定日志实现重试逻辑.
我可以添加一个时间字段并将消息重新发送到同一队列,如果其时间字段有效(即小于当前时间),则此消息将再次消耗,如果不是,则再次将其推送到队列中.
但是这个逻辑会一次又一次地添加相同的日志,直到重试时间正确并且队列将不必要地增长.
是否有更好的方法在Kafka中实现重试逻辑？
apache-kafka kafka-consumer-api kafka-producer-api
apache-kafka ×1
kafka-consumer-api ×1
kafka-producer-api ×1