1.查看topic指令
(1)cd 进入kafka安装目录
(2)执行下面指令,注意修改linux1为你的zookeeper集群对应的节点和端口(默认2181)
bin/kafka-topics.sh --zookeeper linux1:2181 --list
(3)实 *** 演示
2.查看topic内容指令
(1)cd 进入kafka安装目录
(2)执行下面指令,注意修改linux1为你的kafka集群对应的节点和端口(默认9092)
bin/kafka-console-consumer.sh --bootstrap-server linux1:9092 --topic test --from-beginning
(3)实 *** 演示
欢迎分享,转载请注明来源:内存溢出
评论列表(0条)