本文分析的Kafka代碼為kafka-0.8.2.1。另外，由於Kafka目前提供了兩套Producer代碼，一套是Scala版的舊版本；一套是Java版的新版本。雖然Kafka社區極力推薦大家使用Java版本的producer，但目前很多已有的程序還是調用了Scala版的API。今天我們就分析 ...

既然Kafka使用Scala寫的，最近也在慢慢學習Scala的語法，雖然還比較生疏，但是還是想嘗試下用Scala實現Producer和Consumer，並且用HashPartitioner實現消息根據key路由到指定的partition。 Producer: import ...

brokers和消費者使用zk來獲取狀態信息和追蹤消息坐標。 每一個partition是一個有序的，不可變的消息序列。 只有當partition里面的file置換到磁盤文件以后，才開放給消費者來消費。 ...

kerberos簡單介紹 kerberos這一名詞來源於希臘神話“三個頭的狗---地獄之門守護者”后來沿用作為安全認證的概念，該系統設計上 采用客戶端/服務器結構與DES(Data Encrypt ...

一.前言 　　任何消息隊列都是萬變不離其宗都是3部分，消息生產者（Producer）、消息消費者（Consumer）和服務載體（在Kafka中用Broker指代）。那么本篇主要講解Producer端，會有適當的圖解幫助理解底層原理。 　 一.開發應用 　　首先介紹一下開發應用，如何構建一個 ...

粘貼一下這個配置，與我自己的程序做對比，看看能不能完善我的異步帶代碼； ----------------------------------------- 詳解Kafka生產者 ...

一、Kafka設計原理參考： http://blog.csdn.net/suifeng3051/article/details/48053965?locationNum=2 http://www.cnblogs.com/metoy/p/4452124.html 二、常見問題 ...

　　在上一篇kafka入門的基礎之上，本篇主要介紹Kafka的生產者和消費者。 Kafka 生產者　　 　　kafka Producer發布消息記錄到Kakfa集群。生產者是線程安全的，可以在多個線程之間共享生產者實例。一個簡單的例子，使用producer發送一個有序的key/value(鍵值 ...