kafka

1/13ページ

訊息服務百科全書——為什麼使用MQ

為什麼要使用MQ?有如下幾個好處: 解耦 在專案啟動之初來預測將來專案會碰到什麼需求,是極其困難的。訊息系統在處理過程中間插入了一個隱含的、基於資料的介面層,兩邊的處理過程都要實現這一介面。這允許你獨立的擴充套件或修改兩邊的處理過程,只要確保它們遵守同樣的介面約束。 冗餘 有些情況下,處理資料的過程 […]

訊息服務百科全書——Kafka基本原理介紹

 架構 1.1 總體架構 因為Kafka內在就是分散式的,一個Kafka叢集通常包括多個代理。 為了均衡負載,將話題分成多個分割槽,每個代理儲存一或多個分割槽。多個生產者和消費者能夠同時生產和獲取訊息。 一個典型的Kafka叢集中包含若干Producer(可以是web前端產生的Page View,或 […]

訊息服務百科全書——資訊生產與消費

生產者 1.1 負載均衡 生產者直接傳送訊息到分割槽的leader上,中間不需要任何路由選擇。 客戶端控制了訊息將被送到哪個分割槽上。通常能夠使用隨機負荷分擔的方式,或者使用某種標誌來分配。我們提供了介面,允許使用者指定關鍵字來hash到特定的分割槽(語義分割槽),比如,使用user id來作為關鍵 […]

訊息服務百科全書——訊息投遞語義

訊息投遞語義(Message delivery semantics) 有如下幾種可能的訊息傳遞保障: 1、At most once:訊息可能丟失,但是不會重複。 2、At least once:訊息不會丟失,但是可能重複。系統保證每條訊息至少會傳送一次,但在有故障的情況下可能會導致重複傳送。 3、E […]