1. 下载
http://kafka.apache.org/downloads https://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 的版本是否一致 (匹配)
如果在服务器上安装要注意防火墙或安全策略有没有放开对应的端口
参考:
https://www.orchome.com/6
来源: http://www.bubuko.com/infodetail-3313209.html