kafka常用的命令

查看有那些topic

• 进入到 bin目录

1.查看topic
./kafka-topics.sh  --zookeeper node3:2181,node4:2181,node5:2181 --list
2.创建topic
./kafka topics.sh --topic new_top  --partitions 3 zookeeper node3:2181,node4:2181,node5:2181  --replication factor 3

• 模拟测试
• 一台节点当生产者，另一台节点当消费者

1.生产者节点 代码
./kafka-console-producer.sh --broker --list nodel:9092,node2:9092,node3:9092 --topic new_top 
2.消费者节点 代码
./kafka-console-consumer .sh --zookeeper node3:2181,node4:2181,node5:2181 --topic new_top

• 如何在zookeeper中查看生产者元数据

进入zookeeper/bin/zkCli.sh start 
ls /
ls brokers/
ls brokers/topic
ls brokers/topic/partition
ls brokers/topic/partition/查看到 topic的分区
然后进入 ls 分区内 
然后 get 分区内的stage 就可以看到数据了

• 如何在zookeeper中查看消费者元数据

ls /consumer
ls /consumer/......
一直往里进

里面肯定有一个 消费者组。是随机产生的组