消息队列--Springboot整合Kafka

消息队列--Kafka:

由于公司用到了Kafka,所以花点时间了解下。kafka要安装zk,zk要安装jdk且内置有个进程端口号为8080,所以linux上有tomcat给停了,或者换端口



Zk安装:

  1. zk安装启动:https://www.cnblogs.com/rgever/p/10222167.htm

  2. zk安装注意点:https://blog.csdn.net/qq_924485343/article/details/115963637

  3. 腾讯apache镜像(下载kafka和zk的bin包):https://mirrors.cloud.tencent.com/apache




kafka安装:

  1. Kafka修改所需内存大小:https://blog.csdn.net/weixin_30471561/article/details/95719048

  2. 后台启动kafka:https://blog.csdn.net/zhongzunfa/article/details/80817971




kafka内容介绍

:https://www.cnblogs.com/qingyunzong/p/9004509.html (和es很像,这些分布式中间件都具备集群节点,主从复制的特点)




SpringBoot整合Kafka

上述配置好后,只用修改application.yml中bootstrap-servers中地址即可,改成自己的公网

springboot整合kafka:https://www.jianshu.com/p/6ce5d9a96113?utm_campaign=hugo

代码地址:https://gitee.com/empirefree/springboot-message-queue-kafka

总体流程(发布-订阅模式)是

graph LR A(Producer) -->B{kafka} B{kafka} -->|CallBack回调 可选|A(Producer) B -->|Topic.group1| C[Consumer1] B -->|Topic.group2| D[Consumer2]

我曾七次鄙视自己的灵魂:
第一次,当它本可进取时,却故作谦卑;
第二次,当它在空虚时,用爱欲来填充;
第三次,在困难和容易之间,它选择了容易;
第四次,它犯了错,却借由别人也会犯错来宽慰自己;
第五次,它自由软弱,却把它认为是生命的坚韧;
第六次,当它鄙夷一张丑恶的嘴脸时,却不知那正是自己面具中的一副;
第七次,它侧身于生活的污泥中,虽不甘心,却又畏首畏尾。
原文地址:https://www.cnblogs.com/meditation5201314/p/14825615.html