本章介紹如何使用 螞蟻金服 的開源的前端專案 Ant Design Pro ，製作一個helloworld，體驗整個專案的開發、編譯、釋出以及執行流程。專案的執行效果可以點選下面的連結體驗：

一、Kafka消費者原始碼介紹 1.分割槽消費模式原始碼介紹 分割槽消費模式直接由客戶端(任何高階語言編寫)使用Kafka提供的協議向伺服器傳送RPC請求獲取資料，伺服器接受到客戶端的RPC請

Kafka Controller 是 Kafka 的核心元件，在前面的文章中，已經詳細講述過 Controller 部分的內容。在過去的幾年根據大家在生產環境中應用的反饋，Controller 也積累了一些比

title: 自定義log4j2傳送日誌到Kafka tags: log4j2,kafka 為了給公司的大資料平臺提供各專案組的日誌，而又使各專案組在改動上無感知。做了一番調研後才發現log4

在資料密集型的系統架構中，一般會使用Kafka作為中間的緩衝，使用Storm做資料統計時，我們一般會從Kafka中消費訊息，然後把最終的統計結果儲存到Redis中，storm-kafka模組極大方便了

本文來自網易雲社群，轉載務必請註明出處。 背景 訊息中介軟體是用來系統間通訊、非同步解耦、削峰填谷的重要手段，個人認為一個比較靠譜的Mq，應該具備以下特點 控制投遞：訊息消費失敗，支

經常聽後端童鞋提到Kafka 這個詞，加上業務慢慢有了交集，對Kafka 的好奇越來越強烈。索性花點時間，一探究竟，順便擴充套件一下技能樹。 一、Kafka 是什麼？

建立一個ProducerRecord物件，ProducerRecord物件包含 Topic 和 Value ，還可以指定 Key 或 Partition 在傳送ProducerRe

➜ tree . ├── docker-compose.yml └── zoo.cfg 0 directories, 2 files zoo.cfg

前言 在上文 設計一個百萬級的訊息推送系統 中提到訊息流轉採用的是 Kafka 作為中介軟體。 其中有朋友諮詢在大量訊息的情況下 Kakfa 是如何保證訊息的高效及一致性呢？ 正

【51CTO.com原創稿件】Apache Kafka 是一款流行的分散式資料流平臺，它已經廣泛地被諸如 New Relic(資料智慧平臺)、Uber、Square(移動支付公司)等大型公司用來構建可

1. 準備工作 Kafka叢集的搭建可以參考Kafka叢集搭建與配置 Spark叢集的搭建可以參考Hadoop+HBase+Spark+Hive環境

準備工作 安裝java環境 搭建zookeeper叢集 搭建kafka叢集 1. 準備工作 1.1 安裝包 jdk-8u162-linux-x64.tar

在這個示例中，我將資料的儲存和 MongoDB 分離，並建立另一個微服務去處理它。我還添加了 Kafka 為訊息層服務，這樣微服務就可以非同步處理它自己關心的東西了。 下面是這個使用了兩個微服務的簡單的非同步

一、Kafka消費者程式設計模型 1.分割槽消費模型 分割槽消費虛擬碼描述 main() 獲取分割槽的size for index =0 to size create