1.下载
http://kafka.apache.org/downloads
2.解压&启动
tar -xzf kafka_2.11-2.3.0.tgz cd kafka_2.11-2.3.0 ./bin/zookeeper-server-start.sh config/zookeeper.properties & //zk ./bin/kafka-server-start.sh config/server.properties & //kafka
3.创建主题
bin/kafka-topics.sh --create --zookeeper localhost:2181 --replication-factor 1 --partitions 1 --topic test bin/kafka-topics.sh --list --zookeeper localhost:2181 >test
Ps 除手工创建topic外,你也可以配置你的broker,当发布一个不存在的topic时自动创建topic。
kafka项目启动报错:可查看与Spring-Boot的版本是否一致(匹配)
如果在服务器上安装要注意防火墙或安全策略有没有放开对应的端口
参考:
发布者:全栈程序员-用户IM,转载请注明出处:https://javaforall.cn/2580.html原文链接:https://javaforall.cn
【正版授权,激活自己账号】: Jetbrains全家桶Ide使用,1年售后保障,每天仅需1毛
【官方授权 正版激活】: 官方授权 正版激活 支持Jetbrains家族下所有IDE 使用个人JB账号...