美文网首页
kafka单机测试环境搭建

kafka单机测试环境搭建

作者: 码农工号9527 | 来源:发表于2019-08-05 17:31 被阅读0次

单机测试环境可以完全参考这篇文章,亲测可用:
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
可以发现该主题已经删除


1-1.png

查看消费者组: bin/kafka-consumer-groups.sh --bootstrap-server localhost:9092 --list

相关文章

网友评论

      本文标题:kafka单机测试环境搭建

      本文链接:https://www.haomeiwen.com/subject/dgzmdctx.html