kafak命令

启动：
nohup ./bin/kafka-server-start.sh ./config/server.properties &>> /usr/local/kafka_2.12-2.5.0/logs/kafka.log &

测试集群
创建topic
/bin/kafka-topics.sh --create --zookeeper node1:2181,node2:2181,node3:2181 --replication-factor 1 --partitions 1 --topic test

生产者
bin/kafka-console-producer.sh --broker-list 192.168.1.6:9092 --topic test

消费者
bin/kafka-console-consumer.sh --bootstrap-server node1:9092,node2:9092,node3:9092 --topic test

查看topic的分区情况
bin/kafka-topics.sh --zookeeper 192.168.1.6:2181 --describe --topic test

image.png

列出所有的topic
bin/kafka-topics.sh --zookeeper node1:2181,node2:2181,node3:2181 --list