Kafka系列3：深入理解Kafka消費者
p.p1 { margin: 0; font: 14px "Heiti SC Light"; color: rgba(23, 144, 233, 1); background-color: rgba( ...
原文：深入理解RocketMQ的消費者組、隊列、Broker，Topic
遇到的問題：上測試環境，上次描述的鳥問題又出現了，就是生產者發 條數據，我這邊只能收到 條數據。 問題解決： 去控制台看我的消費者啟動情況，貌似沒什么問題 ， 去測試服務器里看日志信息：只有入庫的那條是真的接收到了，其余壓根就沒有接收到，排除入庫過程的代碼問題。到此，問題只鎖定在我的consumer根本沒有接收到丟失的那兩條消息。 仔細思考一下，發現了問題的根源，看圖一的控制台信息，可以發現，生 ...
2019-10-15 15:06 0 3754 推薦指數：
相關推薦
深入理解Kafka核心設計及原理（三）：消費者
轉載請注明出處：https://www.cnblogs.com/zjdxr-up/p/16114877.html 目錄： 3.1 消費者與消費組 3.2 消息消費過程及代碼 3.3 消息消費模式 3.4 位移提交 3.5 位移提交過程導致 ...
RocketMQ源碼詳解 | Broker篇 · 其三：CommitLog、索引、消費隊列
概述 上一章中，已經介紹了 Broker 的文件系統的各個層次與部分細節，本章將繼續了解在邏輯存儲層的三個文件 CommitLog、IndexFile、ConsumerQueue 的一些細節。文章最后，還會對比下 RocketMQ 和 Kafka 的持久化結構與設計的合理性 ...
深入理解阻塞隊列
阻塞隊列（BlockingQueue）是一個支持兩個附加操作的隊列。這兩個附加的操作是：在隊列為空時，獲取元素的線程會等待隊列變為非空。當隊列滿時，存儲元素的線程會等待隊列可用。阻塞隊列常用於生產者和消費者的場景，生產者是往隊列里添加元素的線程，消費者是從隊列里拿元素的線程。阻塞隊列就是生產者存放 ...
RocketMQ 死信隊列 | 消費者出現異常如何處理？
在RocketMQ 重復消費問題 | 訂單系統核心流程引入冪等性機制一文中，我們討論了消息重復消費的問題，比較好的方案是采用在消費側使用業務判斷法來保證接口的冪等性，這樣就能避免消息重復消費的問題。 今天要討論的是消費者代碼執行過程中出現異常，我們應該如何處理？ 手動提交 offset ...
怎么理解 Kafka 消費者與消費組之間的關系?
與生產者對應的是消費者，應用程序可以通過 KafkaConsumer 來訂閱主題，並從訂閱的主題中拉取消息。不過在使用 KafkaConsumer 消費消息之前需要先了解消費者和消費組的概念，否則無法理解如何使用KafkaConsumer。 今天先講解消費者與消費組之間的關系，后續再結合 ...
深入研究RocketMQ消費者是如何獲取消息的
。 消費者組你就可以把它理解為，給一組消費者起一個名字。 假設我們有一個訂單Topic名字是Orde ...
RocketMQ 消費者
本文分析 DefaultMQPushConsumer，異步發送消息，多線程消費的情形。 DefaultMQPushConsumerImpl MQClientInstance 一個客戶端進程只有一個 MQClientInstance 實例 MQClientAPIImpl 和 netty ...