推广 热搜: SEO  网站建设  企业网站  网站  济南  网络优化  设计  优化推广  青岛网站建设  青岛seo 

Docker部署Kafka和Spring Kafka的实现

   2024-04-20 300
核心提示:查看使用文档中的docker-compose.yml因为kafka要搭配zookeeper一起使用,所以文档中包含了zookeeper我修改了一下版本号 以及变量参数这两个参数好像是可以暴露给外网访问的

查看使用文档中的docker-compose.yml


因为kafka要搭配zookeeper一起使用,所以文档中包含了zookeeper


我修改了一下版本号 以及变量参数


这两个参数好像是可以暴露给外网访问的(从其他博客找到的答案,不设置spring kafka 会连接不上)


运行命令docker-compose up -d,就会开启2个容器


进kafka容器使用官网的指南进行测验http://kafka.apache.org/quickstart


docker exec -it {容器id&name} /bin/bash


进入容器之后进入命令目录 cd /opt/kafka/bin/


第一步:新建topic


kafka-topics.sh –create –bootstrap-server 192.168.17.165:9092 –replication-factor 1 –partitions 1 –topic mytest (localhost修改为自己的ip号)


第二步: 发送信息:kafka-console-producer.sh –broker-list 192.168.17.165:9092 –topic mytest


第三步:另开启一个窗口消费信息:kafka-console-consumer.sh –bootstrap-server 192.168.17.165:9092 –topic mytest –from-beginning


则表示已经搭建成功了.


开始搭建Spring Kafka


pom.xml:


配置生产者Config:


配置消费者Config


相关配置来自spring官网kafka文档: https://docs.spring.io/spring-kafka/docs/2.3.1.RELEASE/reference/html/


创建Controller请求后发送信息


配置监听:


使用@KafkaListener注解 ,文档都有相关说明,就不一一解释


run项目,随后请求url 查看日志:


 
反对 0举报 0 收藏 0 打赏 0评论 0
这篇文章由以下公司发布:
 
更多>同类资讯
推荐图文
推荐资讯
点击排行
网站首页  |  关于我们  |  联系方式  |  使用协议  |  版权隐私  |  网站地图  |  排名推广  |  广告服务  |  积分换礼  |  网站留言  |  RSS订阅  |  违规举报