kafka命令合集

一.基本操作

1.启动kafka bin/kafka-server-start.sh -daemon config/server.properties

2.关闭kafka bin/kafka-server-stop.sh

3.查看kafka topic是否支持集群，没反应就是正确 bin/kafka-topics.sh --describe --zookeeper 1.1.1.1:2181,1.1.1.2:2181,1.1.1.3:2181 --topic MyTopic

4.查看当前zookerrper下的kafka集群所有的topic bin/kafka-topics.sh --list --zookeeper 1.1.1.1:2181

5.详细查看topic bin/kafka-topics.sh --describe --zookeeper 1.1.1.1:2181 --topic topic名字

6.创建一个topic，副本备份数1个，分区数1个 bin/kafka-topics.sh --create --zookeeper 1.1.1.1:2181 --replication-factor 1 --partitions 1 --topic topic名字

7.通过list命令查看创建的topic bin/kafka-topics.sh --list --zookeeper 127.0.0.1:2181

8.删除一个topic bin/kafka-topics.sh --zookeeper 1.1.1.1:2181 --delete --topic topic名字

9.改变集群模式为主主，切换主从到主主模式，解决主从模式下，从从选举时间问题 bin/kafka-preferred-replica-election.sh --zookeeper 1.1.1.1:2181

二.生产消费测试

1.发送消息 运行producer并在控制台中输一些消息，这些消息将被发送到服务端： bin/kafka-console-producer.sh --broker-list 127.0.0.1:9092 --topic test This is a message

ctrl+c可以退出发送

2.消费消息 bin/kafka-console-consumer.sh --zookeeper 127.0.0.1:2181 --topic test --from-beginning This is a message

你在一个终端中运行consumer命令行，在另一个终端中运行producer命令行，就可以在一个终端输入消息，另一个终端读取消息。