kafka是一個開源的分布式消息隊列
他提供可靠的集群容錯機制，並保證故障切換時的數據完整性。
無論從性能、可靠性、易用性都強過ActiveMQ（client的API感覺還是不如ActiveMQ好用，文檔也沒有更新到最新版）
下面簡單記錄一下安裝步驟和常用命令。
1、安裝
下載壓縮包並解壓
可以解壓到 /usr/local/kafka
2、配置
vim conf/server.properties
#設置brokerid（從0開始，3個節點分別設為0,1,2，不能重復）
broker.id=0
#設置data目錄，最好不要用默認的/tmp/kafka-logs
log.dirs=/usr/local/kafka/kafka-logs
#設置注冊地址（重要，默認會把本機的hostanme注冊到zk中，客戶端連接時需要解析該hostanme，所以這里直接注冊本機的IP地址，避免hostname解析失敗，報錯java.nio.channels.UnresolvedAddressException或java.io.IOException: Can not resolve address）
advertised.host.name=192.168.xxx
#設置zookeeper地址
zookeeper.connect=zk1.yazuoyw.com:2181,zk2.yazuoyw.com:2181,zk3.yazuoyw.com:2181
3、啟動關閉
#啟動
/usr/local/kafka/bin/kafka-server-start.sh -daemon /usr/local/kafka/config/server.properties
#添加開機啟動
echo '
# start kafka
/usr/local/kafka/bin/kafka-server-start.sh -daemon /usr/local/kafka/config/server.properties
' >> /etc/rc.local
#關閉
/usr/local/kafka/bin/kafka-server-stop.sh
4、常用命令
#查看tocpic列表（--zookeeper指定任意一個zk節點即可，用於獲取集群信息）
/usr/local/kafka/bin/kafka-topics.sh --zookeeper
zk1.yazuoyw.com:2181 --describe
#創建topic（--replication-factor表示復制到多少個節點，--partitions表示分區數，一般都設置為2或與節點數相等，不能大於總節點數）
/usr/local/kafka/bin/kafka-topics.sh --zookeeper
zk1.yazuoyw.com:2181 --create --topic topic1 --replication-factor 2 --partitions 2
#發送消息（--topic 指定topic）
/usr/local/kafka/bin/kafka-console-producer.sh --broker-list kafka1.yazuoyw.com:9092,kafka2.yazuoyw.com:9092,kafka3.yazuoyw.com:9092 --topic topic1
message1
message2
#消費消息
/usr/local/kafka/bin/kafka-console-consumer.sh --zookeeper zk1.yazuoyw.com:2181 --topic topic1
#replica檢查
/usr/local/kafka/bin/kafka-replica-verification.sh --broker-list kafka1.yazuoyw.com:9092,kafka2.yazuoyw.com:9092,kafka3.yazuoyw.com:9092