kafka-retry:卡夫卡重试

Kafka-重试机制和延迟队列 介绍 该项目旨在隔离重试机制和延迟队列的实现。 当我们想到一个容错系统时，我们应该牢记的一件事是如果有错误，我该如何最大程度地减少这种影响？ 广泛使用的标准是重新处理，直到找到成功或尝试次数超过最大限制。 在这种情况下，消息将发送到DLQ。 （死信队列）。 这个怎么运作？ 对于kafka系统，一条消息基本上由HEADERS和PAYLOAD组成。 HEADER是一个基本的KEY-VALUE结构，其中包含kakfa使用的控件属性，例如TOPIC，GROUP_ID等。在其中，我们可以添加自定义键，并基于它们自定义重试策略。 如何使用 让我们想象一个需要与联邦税收系统集成的场景。 这些消息将根据特定主题（例如“ FederalRevenue”）进行处理。 基本思想是，当使用者执行集成并且由于不可用原因而失败时，他会为retry主题生成一条新消息。 此新消息应该