/kafka

springboot 集成kafka 简单案例,以及吞吐量简单测试 (docker安装zookeeper 和 kafka,并利用idea将项目一键部署到docker)--windows环境本地安装得docker

Primary LanguageJava

kafka

springboot 集成kafka 简单案例 (docker安装zookeeper 和 kafka)

一、docker安装kafka zookeeper

  • docker run -d --name zookeeper -p 2181:2181 -t zookeeper 拉取最新版本

  • docker run -d --name kafka -p 9092:9092 --env KAFKA_ADVERTISED_HOST_NAME=localhost -e KAFKA_ZOOKEEPER_CONNECT=192.168.2.12:2181 -e KAFKA_ADVERTISED_LISTENERS=PLAINTEXT://192.168.2.12:9092 -e KAFKA_LISTENERS=PLAINTEXT://0.0.0.0:9092 -e KAFKA_HEAP_OPTS="-Xmx256M -Xms128M" wurstmeister/kafka

  • 版本对应问题

二、idea 一键部署docker(有很多方案,docker-componse.yml<一键集群了解一下>--一般都是linux环境操作)

  • docker 设置:

image

  • 安装idea docker插件:

image

  • 配置测试联通:(一般docker都要开启远程访问连接,貌似windows默认开启,所以如果是其他环境安装docker,要看看)

image

  • 已经编写好的本地项目,并本地打包 mvn clean package:

  • 编写Dockerfile(文件名字不能写错)--具体编写内容可以网上查看,注意 生成得jar包 要和Dockerfile在一个文件夹下,如果不在,在Dockerfile ADD编写得时候要写正确相对对路径(我是放在一个文件夹下了)

image

  • 配置docker 发布部署启动项:

image image

  • run 执行 看日志是否发布成功:

image

  • 测试(注意端口是docker端暴露得端口,可以在docker 我们发布的容器查看日志)

image image

项目发布docker过程遇到得报错:

  • (1)Dockerfile中jar得路径不对,找不到本地打jar包;
  • (2)配置启动项时候,绑定得映射端口 之前有重复得;
  • (3)成功发布好,但是日志显示没有 no main....类似打得jar有问题

本地、docker 安装启动kafka报错:

  • (1)oom 等 类似于jvm参数得问题--配置启动文件中得jvm参数(没有解决--很多事linux环境解决方案)
  • (2)docker 拉取镜像报错,重启docker 获取换一下镜像路径