下载Kafka
注意:下载并使用Kafka前,必须安装Zookeeper!zookeeper安装文档:https://blog.csdn.net/u014641168/article/details/123901786
kafka官网下载地址:https://kafka.apache.org/downloads
linux中使用wget命令,远程下载kafka
wget https://archive.apache.org/dist/kafka/2.8.1/kafka_2.12-2.8.1.tgz --no-check-certificate
版本的话当然越新越好,对SpringBoot本版暂无要求,如果你有想说的,欢迎在评论区讨论。
安装
1、解压压缩包到/usr/local/
目录
tar -zxvf ./kafka_2.12-2.8.1.tgz -C /usr/local/
2、进入/usr/local/
目录
cd /usr/local/
3、修改原始名称
mv ./kafka_2.12-2.8.1/ kafka2.12
4、进入Kafka并修改配置文件
cd kafka2.12
vim config/server.properties
修改其中的:
broker.id=0
log.dir=/usr/local/kafka/kafka-logs
#配置zookeeper管理kafka的路径
zookeeper.connect=localhost:2181
#配置kafka的监听端口
listeners=PLAINTEXT://:9092
#把kafka的地址端口注册给zookeeper,如果是远程访问要改成外网IP
advertised.listeners=PLAINTEXT://外网IP:外网端口
启动
必须先启动zookeeper!!!
kafka启动命令:
bin/kafka-server-start.sh -daemon config/server.properties
kafka停止命令:
bin/kafka-server-stop.sh
创建Topic
1、进入到Kafka目录下,创建一个名为testTopic
的Topic。
bin/kafka-topics.sh --create --zookeeper localhost:2181 --replication-factor 1 --partitions 1 --topic testTopic
2、查看创建的Topic列表。
bin/kafka-topics.sh --list --zookeeper localhost:2181
测试通信
1、连接生产者,命令后面需要对应 Topic 名称。
bin/kafka-console-producer.sh --broker-list localhost:9092 --topic testTopic
2、连接消费者,需要连接消费者的Topic
bin/kafka-console-consumer.sh --bootstrap-server localhost:9092 --topic testTopic --from-beginning
通过以上步骤,就成功安装kafka了,这个时候就可以通过java开发工具连接进行开发了。
详细介绍:https://www.cnblogs.com/yclh/p/14894712.html
Kafka账号密码配置:https://blog.csdn.net/u014641168/article/details/130841314
其他
自己做的小商城,开发技术 SpringCloud + Nacos + 支付宝支付 + Vue
感兴趣的可以相互讨论技术!
传送门:https://store.ityao.cn/文章来源:https://www.toymoban.com/news/detail-485880.html
顺便说一下,国内又一款开源软件Wall,搭建特别简单,可以搭建个人照片墙和视频墙,有兴趣可以看下教程:https://blog.csdn.net/u014641168/article/details/129396364文章来源地址https://www.toymoban.com/news/detail-485880.html
到了这里,关于Kafka 在CentOS下安装的文章就介绍完了。如果您还想了解更多内容,请在右上角搜索TOY模板网以前的文章或继续浏览下面的相关文章,希望大家以后多多支持TOY模板网!