Kafka命令行操作

1)查看当前集群中已存在的主题topic

代码语言：javascript复制

bin/kafka-topics.sh --zookeeper hd09:2181 --list

2)创建topic

代码语言：javascript复制

bin/kafka-topics.sh --zookeeper hd09-01:2181 --create --replication-facto r 3 --partitions 1 --topic guan

--zookeeper 连接zk集群 --create 创建 --replication-factor 副本 --partitions 分区 --topic 主题名

3)删除主题

代码语言：javascript复制

bin/kafka-topics.sh --zookeeper hd09-01:2181 --delete --topic guan 

4)发送消息 生产者启动:

代码语言：javascript复制

bin/kafka-console-producer.sh --broker-list hd09-01:9092 --topic guan

消费者启动:

代码语言：javascript复制

 bin/kafka-console-consumer.sh --bootstrap-server hd09-01:9092 --topic guan --from-beginning

5)查看主题详细信息

代码语言：javascript复制

bin/kafka-topics.sh --zookeeper hd09-01:2181 --describe --topic guan

zookeeper replication zk 集群 连接

0 人点赞