卸载Kafka
连接Zookeeper客户端
sh zkCli.sh -server 127.0.0.1:2181
删除Kafka在ZK上的节点，如图所示，有consumers，admin，config，controller，brokers，controller_epoch等节点
rmr /path
安装Kafka
去官网下载对应版本的压缩包 https://kafka.apache.org/downloads解压缩对应文件
tar -zxvf kafka_2.12-2.6.0.tgz
设置配置文件
vim config/server.properties
①设置**broker.id**的值，每个节点这个值要不一样
②设置Zookeeper的地址**zookeeper.connect**
③设置日志文件存储地址**log.dirs**
④设置**advertised.listeners**为本机的地址和端口号
启动Kafka
/opt/xxx/kafka_2.12-2.6.0/bin/kafka-server-start.sh -daemon /opt/xxx/kafka_2.12-2.6.0/config/server.properties
使用
---------------------与zk交互-----------------------
#查看topic列表
bin/kafka-topics.sh --zookeeper node01:2181 --list
#创建topic
bin/kafka-topics.sh --zookeeper node01:2181 --create --topic demo01_topic--partitions 3 --replication-factor 3
# topic：定义topic的名称
# partitions：分区数量
# replication-factor：副本数量
#删除topic，当配置delete.topic.enable=true时是物理删除，否则为逻辑删除
bin/kafka-topics.sh --zookeeper node01:2181 --delete --topic demo01_topic
#查看topic详细信息
bin/kafka-topics.sh --zookeeper node01:2181 --describe --topic demo01_topic
#修改topic的分区数
bin/kafka-topics.sh --zookeeper node01:2181 --alter --topic demo01_topic--partitions 4
---------------------与broker交互-----------------------
#启动一个生产者
bin/kafka-console-producer.sh --topic demo01_topic--broker-list node01:9092
---------------------与bootstrap交互-----------------------
#启动一个消费者
bin/kafka-console-consumer.sh --topic demo01_topic--bootstrap-server node02:9092
