今天学习了一下kafka的原理以及相关命令,把kafka相关的常用命令整理出来
直接进入到kafka的bin目录下,执行下面的命令
创建主题topic(3个分区,1个副本)
bin/kafka-topics.sh
--create --zookeeper 162.168.2.23:2181 --replication-factor1--partitions3--topicnca_new
查看所有的topic
bin/kafka-topics.sh --list --zookeeper 162.168.2.23:2181
查询topic的描述信息
bin/kafka-topics.sh --describe --zookeeper 162.168.2.23:2181--topic nca_new
查看生产者
bin/kafka-console-producer.sh --broker-list 162.168.2.23:9092 --topic nca_new
查看消费者
bin/kafka-console-consumer.sh --zookeeper 162.168.2.23:2181 --topic nca_new
例子
[public@linux23bin] ./kafka-topics.sh --list --zookeeper 162.168.2.23:2181
business_new
business_basic
nca_new
[public@linux23bin] ./kafka-topics.sh --describe --zookeeper 162.168.2.23:2181--topic nca_new #查看nca_new的描述信息
Topic:nca_newPartitionCount:3ReplicationFactor:1Configs:
Topic:nca_newPartition:0Leader:0Replicas:0Isr:0
Topic:nca_newPartition:1Leader:0Replicas:0Isr:0
Topic:nca_newPartition:2Leader:0Replicas:0Isr:0