kafka基本操作

shell脚本启动

可以手动写一个shell脚本,来简化启动和关闭命令:
kafka启动&关闭脚本:

这里的 -deamon表示后台启动

zookeeper启动&关闭脚本:

cd 到脚本路径,更改执行权限:

chomd 777 zookeeper.sh
chmod 777 kafka.sh

先启动zookeeper:

./zookeeper.sh start

再启动kafka:

./kafka.sh start

命令行指令

1、查看当前服务器中的所有topics
需要cd到kafka的bin目录下

cd $kafka_homein
bash kafka-topics.sh --list --zookeeper 127.0.0.1:2181

我们需要指定运行zookeeper的服务器ip与端口,由于我是在自己的笔记本开启的所以ip就是本机回环,zookeeper默认端口是2181

这里显示我已经创建了一个web_log主题

2、创建主题
格式为:

bash kafka-topics.sh --create --zookeeper 127.0.0.1:2181 --topic <topic名> --partitions <指定分区数量> --replication-factor <指定副本数量>
创建时需要注意,副本数不能大于broker数,否则会出错!(其实就相当于说同一个主题的副本不能落在同一台机器上,否则副本就没有存在的意义啦)

bash kafka-topics.sh --create --zookeeper 127.0.0.1:2181 --topic hello --partitions 2 --replication-factor 1

再次查看主题:

3、查看主题信息

bash kafka-topics.sh --describe --topic hello --zookeeper 127.0.0.1:2181

4、删除主题

bash kafka-topics.sh --delete --topic hello --zookeeper 127.0.0.1:2181

删除主题需要注意,我们如果在server.properties中设置了delete.topic.enable=true之后,才会生效

查看主题:

原文地址:https://www.cnblogs.com/sebuntin2020/p/12518167.html