kafka命令合集

2021-07-07 10:22:53 浏览数 (1)

一.基本操作

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

0 人点赞