文件名称：kafka-retry:卡夫卡重试
文件大小：61KB
文件格式：ZIP
更新时间：2024-05-06 05:27:27
Go
Kafka-重试机制和延迟队列 介绍 该项目旨在隔离重试机制和延迟队列的实现。 当我们想到一个容错系统时，我们应该牢记的一件事是如果有错误，我该如何最大程度地减少这种影响？ 广泛使用的标准是重新处理，直到找到成功或尝试次数超过最大限制。 在这种情况下，消息将发送到DLQ。 （死信队列）。 这个怎么运作？ 对于kafka系统，一条消息基本上由HEADERS和PAYLOAD组成。 HEADER是一个基本的KEY-VALUE结构，其中包含kakfa使用的控件属性，例如TOPIC，GROUP_ID等。在其中，我们可以添加自定义键，并基于它们自定义重试策略。 如何使用 让我们想象一个需要与联邦税收系统集成的场景。 这些消息将根据特定主题（例如“ FederalRevenue”）进行处理。 基本思想是，当使用者执行集成并且由于不可用原因而失败时，他会为retry主题生成一条新消息。 此新消息应该
【文件预览】：
kafka-retry-master
----pkg()
--------retry()
--------config()
--------delay()
--------kafka()
--------message()
--------service()
----cmd()
--------retry()
----extra()
--------diagram.drawio(2KB)
--------diagram.png(35KB)
----deploy()
--------service.yaml.erb(305B)
--------deployment.yaml.erb(1KB)
----internal()
--------util()
----Dockerfile(630B)
----docker-compose.yaml(493B)
----.gitignore(7B)
----go.sum(18KB)
----.dockerignore(34B)
----README.md(2KB)
----application.yaml(555B)
----go.mod(213B)