今天学习了一下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

‘Leader’:该节点复制所有指定分区的读写，节点的领导都是随机选择的

‘Replicas’:备份的节点

‘Isr’:备份节点的集合，也就是活着的节点

‘Partition’:分区号

‘PartitionCount’:当前topic的总的分区数