卸载并且重装Kafka
卸载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/download
·
卸载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
更多推荐
已为社区贡献3条内容
所有评论(0)