单机测试环境可以完全参考这篇文章,亲测可用:
https://blog.csdn.net/weixin_43650254/article/details/89603751
守护启动zookeeper和kafka:
先启动zookeeper:nohup bin/zookeeper-server-start.sh config/zookeeper.properties &
在启动kafka:nohup bin/kafka-server-start.sh config/server.properties &
创建测试topic后如果要删除该topic,参考以下步骤:
首先删除topic的命令为:bin/kafka-topics.sh --delete --zookeeper 127.0.0.1:2181 --topic topic
注:
127.0.0.1:2181为【zookeeper server】 的host和端口
topic 为要删除的主题
此时如果kafaka启动时加载的配置文件中server.properties没有配置delete.topic.enable=true,那么此时的删除并不是真正的删除,而是把topic标记为:marked for deletion
做法:
vim server.properties文件 shift+g切到最后一行 添加delete.topic.enable=true 保存,重启kafka
再次执行:bin/kafka-topics.sh --delete --zookeeper 127.0.0.1:2181 --topic topic
查看主题:./bin/kafka-topics.sh --zookeeper 192.168.13.131:2181 --list
可以发现该主题已经删除
查看消费者组: bin/kafka-consumer-groups.sh --bootstrap-server localhost:9092 --list