个人博客

把正在理解的事,写成可以回访的记录。

关于软件、系统设计与持续学习。文章由 Notion 写作并在这里发布。

目前已发布 302 篇文章。

筛选结果

找到的文章

5

当前筛选标签:#消息中间件清除筛选

死信队列的实现

Kafka 中的 死信队列(Dead Letter Queue, DLQ) 实现,并不是 Kafka 原生内置的功能,而是通过 业务逻辑约定 或 框架支持 来实现的。它的本质是:在消费失败后将消息主动发送到另一个特殊的 Topic 中,由开发者或框架负责这部分逻辑。

Kafka消息积压的处理方式

消息积压是指在 Kafka 消费者无法及时消费消息时,导致消息在 Topic 中的分区积压(即未消费的消息数量不断增加)。这种情况通常会发生在以下场景中: • 消费者的消费能力不足,处理速度慢; • 消费者实例数量不足,无法处理大量消息; • 消费者与生产者之间的处理速度差异较大。 为了确保系统的健康运行,及时处理消息积压是非常重要的。下面将介绍几种常见的解决方案。

Kafka分区数的配置参考

Kafka 的分区(Partition)数是决定 并行度、吞吐能力、可扩展性与消息顺序性 的关键参数。在实际生产环境中合理配置分区数,是设计 Kafka 架构的重要一环。

主题索引

按主题浏览

展开全部标签