当前位置: 首页 > 编程笔记 >

Docker部署Kafka以及Spring Kafka实现

仲孙夕
2023-03-14
本文向大家介绍Docker部署Kafka以及Spring Kafka实现,包括了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-compose部署zk+kafka+storm集群的实现,包括了docker-compose部署zk+kafka+storm集群的实现的使用技巧和注意事项,需要的朋友参考一下 集群部署总览 172.22.12.20 172.22.12.21 172.22.12.22 172.22.12.23 172.22.12.24 zoo1:2181 zoo2:2182 zoo3:2

  • 我已经在集群中配置了3个kafka,我正在尝试与sping-kafka一起使用。 但是在我杀死kafka领导者后,我无法发送其他消息到队列。 我将Spring.kafka.bootstrap-servers属性设置为:“kafka-1:9092;kafka-2:9093,kafka-3:9094”以及我的主机文件中的所有名称。 Kafka0.10版 有人知道如何正确配置? 编辑 我测试过一个东西,

  • 本文向大家介绍Docker部署web项目的实现,包括了Docker部署web项目的实现的使用技巧和注意事项,需要的朋友参考一下 上一篇已经安装好docker服务,下面继续介绍如何部署web项目 一:随便创建目录dock,准备好如下文件: 二、编写Dockerfile,通过它能快速地构建docker镜像 新增如下配置 解释: (1)FROM centos 表示从docker官方仓库中获取centos

  • 本文向大家介绍Docker实践--部署Nodejs应用,包括了Docker实践--部署Nodejs应用的使用技巧和注意事项,需要的朋友参考一下 这个例子的目标是为了向大家展示如何在Docker的container里运行Node.js程序。我会先创建一个简单的Node.js web app,来构建一个镜像。然后基于这个Image运行一个container。从而实现快速部署。 由于网络的原因我的Nod

  • 目前 AKShare 数据接口是基于 Python 开发的,鉴于部分其他语言的用户难以在短时间部署 AKShare 的 Python 使用环境,特此提供基于虚拟化容器技术 Docker 的使用教程。 安装 Docker 官方安装指导 Windows 10:安装教程 Mac:安装教程 Ubuntu:安装教程 CentOS:安装教程 第三方安装指导 Docker 安装教程 建议 Windows 7 和

  • 本文向大家介绍Docker CentOS7的系统上安装部署以及基础教程,包括了Docker CentOS7的系统上安装部署以及基础教程的使用技巧和注意事项,需要的朋友参考一下 说明: 本文介绍如何在CentOS7的系统上安装部署Docker环境,本文参考Docker官方文档如下链接: https://docs.docker.com/engine/installation/centos/ CentO