zl程序教程

您现在的位置是:首页 >  大数据

当前栏目

Kafka命令行操作

2023-06-13 09:17:20 时间

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

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

2)创建topic

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)删除主题

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

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

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

消费者启动:

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

5)查看主题详细信息

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