agent1 exec source + memory channel + avro sink agent2  avro source + memory channel  模擬實際工作中的場景，ag

為什麼我們要用MQ？ 最關鍵點我認為是解耦，這樣各系統間不用有太多的相互依賴，按需消費即可。再者是非同步，提高服務效能。然後就是削峰，防止過多流量湧入而給伺服器帶來壓力。 那用MQ會有哪些問題呢？我們呼叫介面

在一個高併發系統中對流量的把控是非常重要的，當巨大的流量直接請求到我們的伺服器上沒多久就可能造成介面不可用，不處理的話甚至會造成整個應用不可用。 比如最近就有個這樣的需求，我作為客戶端要向kafka生產資料

NTT 是一家全球電信公司，總部設在日本東京。在《財富》世界 500 強中，NTT 是世界第四大電信公司。NTT 通訊 (NTT Com) 是 NTT 的子公司，其全球 IP 網路 (GIN) 業務部擁有並運營

一、前言 訊息佇列中介軟體（簡稱訊息中介軟體）是指利用高效可靠的訊息傳遞機制進行與平臺無關的資料交流，並基於資料通訊來進行分散式系統的整合。通過提供訊息傳遞和訊息排隊模型，它可以在分散式環境下提供應用解耦、

在zk中會儲存AR（Assigned Replicas）列表，其中包含了分割槽所有的副本，其中 AR = ISR+OSR ISR（in sync replica）：是kafka動態維護的一組同步副本

最近開發閘道器服務的過程當中，需要用到kafka轉發訊息與儲存日誌，在進行壓測的過程中由於是多執行緒併發操作kafka producer 進行非同步send，發現send耗時有時會達到幾十毫秒的阻塞，很大程度上

微服務自成立以來就以不同的方式相互溝通。有些人更喜歡使用HTTP REST API，但這些API有自己的排隊問題，而有些則更喜歡較舊的訊息佇列，比如RabbitMQ，它們帶有擴充套件和操作方面的問題。 以K

為什麼使用訊息佇列 其實就是問問你訊息佇列都有哪些使用場景，然後你專案裡具體是什麼場景，說說你在這個場景裡用訊息佇列是什麼？ 面試官問你這個問題，期望的一個回答是說，你們公司有個什麼業務場景，這個業務場

想深入瞭解分散式架構設計，想提升精進自己的技術棧，送你以下最新分享的史上最全【分散式架構設計23期資料合集】，每篇乾貨！每篇貨幹！篇篇原創！已有近300位碼兄領取啦~ Redis的高可用

背景： Kafka多機房（多AZ）部署可以保證資料容災和高穩定性。但是多機房部署如何解決資料一致性的問題？ 目的： Kafka叢集多機房（多AZ部署）解決資料一致性的問題。 部署方案概況：

來源：http://blog.csdn.net/suifeng3051/article/details/38657465 1.Kafka提供了兩套API給Consumer

在今年的十月份，MongoDB 宣佈其開源許可證從 GNU AGPLv3 切換到 Server Side Public License (SSPL)，十一月份，圖資料庫 Neo4j 也宣佈企業版徹底閉源。就在昨

在前面的例子中，我们介绍了如何配置kafka服务端和客户端的SSL链接。 这个前提必须得有证书，如果已经有证书了，或者有现成的CA，那么可以自行签出证书即可；如果没有证书也没有CA服务器，那么必须生成一套测

零、背景 最近在做一個kafka相關專案時，遇到一個悖論問題：業務即想要資料有序，又想要高效能，還想要高可靠。 這個初步看顯然不可能。 有序就要一個一個發，而且只能上個包正常返回時才能發下一個。