golang kafka 1

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文件，写入以下内容保存：
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目录，启动、停止、重启分和查看当前节点状态（包括集群中是何角色）别执行：
./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目录下创建个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. 创建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 ： 指定创建topic动作
--topic ：指定新建topic的名称
--zookeeper ： 指定kafka连接zk的连接url，该值和server.properties文件中的配置项{zookeeper.connect}一样
--config ：指定当前topic上有效的参数值，参数列表参考文档为: Topic-level configuration
--partitions ：指定当前创建的kafka分区数量，默认为1个
--replication-factor ：指定每个分区的复制因子个数，默认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分区数量只允许增加，不允许减少

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

启动生产者，往"test0"这个Topic中发送消息：
bin/kafka-console-producer.sh --topic test0 --broker-list 127.0.0.1:9092 
 
启动消费者，从"test0"这个Topic中消费消息，其中"--from-beginning"为可选参数，表示要从头消费消息：
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