这篇文章主要介绍了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 查看日志:
就配置成功了.
以上就是本文的全部内容，希望对大家的学习有所帮助，也希望大家多多支持。
免责声明：本站资源来自互联网收集,仅供用于学习和交流,请遵循相关法律法规,本站一切资源不代表本站立场,如有侵权、后门、不妥请联系本站删除！
更新日志
- 群星《红色经典》限量1：1母盘直刻[低速原抓WAV+CUE]
- 苗子杰.1993-SUN.SHINE【歌林】【WAV+CUE】
- 吕方.1990-不舍得你【华纳】【WAV+CUE】
- 刘若英.2005-一整夜【大熊星】【WAV+CUE】
- 刘锐/王星《牧者影视配乐精选·贰》[FLAC/分轨][271.13MB]
- 林一峰《作业》[320K/MP3][185.25MB]
- 林一峰《作业》[FLAC/分轨][511.47MB]
- 魔兽世界永久60级奶骑天赋怎么点 永久60级奶骑天赋推荐
- 魔兽世界永久60级矮人牧师怎么玩 永久60级矮人牧师玩法指南
- 炉石传说40血卡组代码一览 2024最新全职业40血卡组代码大全
- 《如龙：极》NS实体版确认！35美元 25年3月发货
- 日本离谱忍者游戏将登NS：手柄插进屁股进行对决
- 《神之天平外传》NS版今日发售 可独立于本体运行
- 群星《24K德国HD金碟红色经典》2CD[WAV+CUE]
- 妙音唱片群星《红色经典DSD1-2》2CD[低速原抓WAV+CUE]