linux安裝java
https://www.cnblogs.com/liugh/p/6623530.html
https://download.oracle.com/otn-pub/java/jdk/8u201-b09/42970487e3af4f5aa5bca3f542482c60/jdk-8u201-linux-x64.tar.gz
/home/user/wz/jdk1.8.0_201

#Java Env
export JAVA_HOME=/usr/jdk1.8.0_121
export CLASSPATH=.:$JAVA_HOME/lib/dt.jar:$JAVA_HOME/lib/tools.jar
export PATH=$PATH:$JAVA_HOME/bin


單機(jī)配置zookeeper
https://www.cnblogs.com/lsdb/p/7297731.html
mkdir data
mkdir logs
在conf目錄下新建zoo.cfg文件，寫(xiě)入以下內(nèi)容保存：
tickTime=2000
dataDir=/home/user/wz/zookeeper-3.5.4-beta/data
dataLogDir=/home/user/wz/zookeeper-3.5.4-beta/logs
clientPort=2181

進(jìn)入bin目錄，啟動(dòng)胖喳、停止仙粱、重啟分和查看當(dāng)前節(jié)點(diǎn)狀態(tài)（包括集群中是何角色）別執(zhí)行：
./zkServer.sh start
./zkServer.sh stop
./zkServer.sh restart
./zkServer.sh status


-----------------------------------------------------------
下載Binary包
https://www.apache.org/dyn/closer.cgi?path=/kafka/2.1.0/kafka_2.11-2.1.0.tgz
bin/kafka-server-start.sh config/server.properties &
# 下面命令需要在logs目錄下創(chuàng)建個(gè)1.log文件藕届，nohub使關(guān)閉shell后進(jìn)程還運(yùn)行
nohup bin/kafka-server-start.sh config/server.properties >logs/1.log 2>&1 &

java.nio.file.NoSuchFileException: config/server.properties

只能從bin目錄上一級(jí)運(yùn)行勺鸦，否則找不到config下的配置

-----------------------------------
使用
 -1. 查看幫助信息
bin/kafka-topics.sh --help

-2. 創(chuàng)建Topic  
bin/kafka-topics.sh --create --topic test0 --zookeeper 127.0.0.1:2181 --config max.message.bytes=12800000 --config flush.messages=1 --partitions 5 --replication-factor 1

--create ： 指定創(chuàng)建topic動(dòng)作
--topic ：指定新建topic的名稱(chēng)
--zookeeper ： 指定kafka連接zk的連接url妨退，該值和server.properties文件中的配置項(xiàng){zookeeper.connect}一樣
--config ：指定當(dāng)前topic上有效的參數(shù)值讽坏，參數(shù)列表參考文檔為: Topic-level configuration
--partitions ：指定當(dāng)前創(chuàng)建的kafka分區(qū)數(shù)量锭魔，默認(rèn)為1個(gè)
--replication-factor ：指定每個(gè)分區(qū)的復(fù)制因子個(gè)數(shù)，默認(rèn)1個(gè)

-3. 查看當(dāng)前Kafka集群中Topic的情況
bin/kafka-topics.sh --list --zookeeper 127.0.0.1:2181

-4. 查看對(duì)應(yīng)topic的描述信息
bin/kafka-topics.sh --describe --zookeeper 127.0.0.1:2181  --topic test0

-5. Topic信息修改
bin/kafka-topics.sh --zookeeper 127.0.0.1:2181 --alter --topic test0 --config max.message.bytes=128000
bin/kafka-topics.sh --zookeeper 127.0.0.1:2181 --alter --topic test0 --delete-config max.message.bytes
bin/kafka-topics.sh --zookeeper 127.0.0.1:2181 --alter --topic test0 --partitions 10 
bin/kafka-topics.sh --zookeeper 127.0.0.1:2181 --alter --topic test0 --partitions 3 ## Kafka分區(qū)數(shù)量只允許增加路呜，不允許減少

-6. Topic刪除
bin/kafka-topics.sh --delete --topic test0 --zookeeper 127.0.0.1:2181

啟動(dòng)生產(chǎn)者迷捧，往"test0"這個(gè)Topic中發(fā)送消息：
bin/kafka-console-producer.sh --topic test0 --broker-list 127.0.0.1:9092 
 
啟動(dòng)消費(fèi)者，從"test0"這個(gè)Topic中消費(fèi)消息拣宰，其中"--from-beginning"為可選參數(shù)党涕，表示要從頭消費(fèi)消息：
bin/kafka-console-consumer --bootstrap-server localhost:9092 --topic test0 --from-beginning

-------------------------------------
golang配置
go get github.com/Shopify/sarama
go get github.com/bsm/sarama-cluster