@消息處理 / 博客 RSS 訂閱

Nov 21 2025

mob64ca13fbd761 - Kafka03--Kafka消費者使用方式

主要步驟 Kafka消費者的使用流程主要包括配置消費者、訂閲主題、拉取消息、處理消息和提交偏移量等關鍵步驟。 消費者配置與初始化 必須配置bootstrap.servers（Kafka集羣地址）、group.id（消費者組ID）和序列化器推薦使用手動提交偏移量以保證消息處理的可靠性

偏移量 , 消息處理 , 分佈式 , kafka , 前端開發 , ide , Javascript

收藏 評論

Dec 27 2025

Python灑灑水啦 - RocketMQ 的消息堆積問題如何解決？

一、先搞懂：消息堆積的核心原因 消息堆積本質是「生產速度 消費速度」，常見誘因： 消費端：消費線程數不足、業務邏輯耗時久、消費端故障 / 重啓、消費異常重試頻繁； 生產端：突發流量（如秒殺）導致消息量暴增； 集羣端：Broker 性能瓶頸（磁盤 IO / 網絡帶寬不足）、隊列數配置不合理、消息堆積閾值未監控。 二、應急處理：快

機器學習 , 業務邏輯 , 消息處理 , 人工智能 , JAVA

收藏 評論