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


單機配置zookeeper
https://www.cnblogs.com/lsdb/p/7297731.html
mkdir data
mkdir logs
在conf目錄下新建zoo.cfg文件，寫入以下內(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

進入bin目錄，啟動、停止、重啟分和查看當前節(jié)點狀態(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)建個1.log文件，nohub使關閉shell后進程還運行
nohup bin/kafka-server-start.sh config/server.properties >logs/1.log 2>&1 &

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

只能從bin目錄上一級運行，否則找不到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動作
--topic ：指定新建topic的名稱
--zookeeper ： 指定kafka連接zk的連接url，該值和server.properties文件中的配置項{zookeeper.connect}一樣
--config ：指定當前topic上有效的參數(shù)值，參數(shù)列表參考文檔為: Topic-level configuration
--partitions ：指定當前創(chuàng)建的kafka分區(qū)數(shù)量，默認為1個
--replication-factor ：指定每個分區(qū)的復制因子個數(shù)，默認1個

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

-4. 查看對應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

啟動生產(chǎn)者，往"test0"這個Topic中發(fā)送消息：
bin/kafka-console-producer.sh --topic test0 --broker-list 127.0.0.1:9092 
 
啟動消費者，從"test0"這個Topic中消費消息，其中"--from-beginning"為可選參數(shù)，表示要從頭消費消息：
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