歡迎關注公眾號：n平方 本文主要介紹【 Kafka Streams的架構和使用 】 目標 瞭解kafka streams的架構。 掌握kafka streams程式設計。

在開源世界裡，Apache Storm專案是流處理的先鋒。Storm最早由Nathan Marz和創業公司BackType的一個團隊開發，後來才被Apache基金會接納。Storm提供了低延遲的流處理，但是它

1.ant安裝 請從官網下載ant的*.zip格式的安裝包， Windows建議下載*.zip版本， Linux建議下載*.gz版本。 2.配置環境變數

歡迎關注公眾號：n平方 本文主要介紹【KafkaStreams 】 簡介 Kafka Streams編寫關鍵任務實時應用程式和微服務的最簡單方法，是一個用於構建應用程式和微服務的客戶

如何保證訊息不被重複消費？或者說，如何保證訊息消費的冪等性？ 面試題剖析 回答這個問題，首先你別聽到重複訊息這個事兒，就一無所知吧，你 先大概說一說可能會有哪些重複消費的問題 。 首先，比如

加密，是以某種特殊的演算法改變原有的資訊資料，使得未授權的使用者即使獲得了已加密的資訊，但因不知解密的方法，仍然無法瞭解資訊的內容 概念 資料加密的基本過程就是對原來為明文的檔案或資料按某種演算法進行

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

微信公眾號： 深廣大資料Club 關注可瞭解更多大資料相關的資訊。問題或建議，請公眾號留言; 如果你覺得深廣大資料Club對你有幫助，歡迎轉發朋友圈 本文介紹如何部署

近日，Apache Kylin 社群很高興地宣佈，Apache Kylin v2.6.0 正式釋出。 Apache Kylin 是一個開源的分散式分析引擎，旨在為極大資料集提供 SQL 介面和多維分析（OL

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

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

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

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

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

Apache Flink（以下簡稱Flink）專案是大資料處理領域最近冉冉升起的一顆新星，其不同於其他大資料專案的諸多特性吸引了越來越多人的關注。本文將深入分析Flink的一些關鍵技術與特性，希望能夠幫助讀者對