一.基本操作
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命令行,就可以在一个终端输入消息,另一个终端读取消息。