Docker部署Kafka以及Spring Kafka实现
这篇文章主要介绍了Docker部署Kafka以及Spring Kafka实现,文中通过示例代码介绍的非常详细，对大家的学习或者工作具有一定的参考学习价值,需要的朋友可以参考下
从https://hub.docker.com/查找kafka
第三个活跃并stars数量多 进去看看使用
我们使用docker-compose来构建镜像
查看使用文档中的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 查看日志:
就配置成功了.
以上就是本文的全部内容，希望对大家的学习有所帮助，也希望大家多多支持脚本之家。
相关文章
本文主要介绍了Docker安装部署Neo4j的保姆级教程,文中通过示例代码介绍的非常详细,对大家的学习或者工作具有一定的参考学习价值,需要的朋友们下面随着小编来一起学习学习吧2023-08-08
这篇文章主要介绍了如何修改docker官方镜像内部内容并重新build镜像问题,具有很好的参考价值,希望对大家有所帮助,如有错误或未考虑完全的地方,望不吝赐教2024-08-08
这篇文章主要介绍了docker mysql镜像制作并自动安装脚本,主要包括centos7环境下 一键制作mysql docker镜像并安装，对docker 制作mysql镜像shell脚本感兴趣的朋友一起看看吧2022-05-05
这篇文章主要介绍了Docker 隔离与限制原理，对于 Docker 等大多数 Linux 容器来说，Cgroups 技术是用来制造约束的主要手段，而 Namespace 技术则是用来修改进程视图的主要方法，下文相关介绍,需要的朋友可以参考一下2022-04-04
本文主要介绍了docker配置pytorch环境来进行训练的方法步骤,从零开始配置,包括换源,安装下载,具有一定的参考价值,感兴趣的可以了解一下2024-03-03
这篇文章主要介绍了使用 Docker 企业版搭建自己的私有注册服务器的相关资料,需要的朋友可以参考下2018-11-11
这篇文章主要介绍了Docker Volumn容器间共享数据的实现，文中通过示例代码介绍的非常详细，对大家的学习或者工作具有一定的参考学习价值，需要的朋友们下面随着小编来一起学习学习吧2020-01-01
本文主要介绍了docker run命令的使用小结,文中通过示例代码介绍的非常详细,对大家的学习或者工作具有一定的参考学习价值,需要的朋友们下面随着小编来一起学习学习吧2025-01-01
本文主要介绍了Docker部署postgresql的方法实现,文中通过示例代码介绍的非常详细,对大家的学习或者工作具有一定的参考学习价值,需要的朋友们下面随着小编来一起学习学习吧2025-01-01
这篇文章主要介绍了Docker运行模式之-d和-it的区别与选择详细对比的相关资料,Docker中-d用于后台运行服务,不阻塞终端；-it提供交互终端,支持用户操作,需要的朋友可以参考下2025-05-05
最新评论