docker安装kafka(wurstmeister)

本文涉及的产品
服务治理 MSE Sentinel/OpenSergo,Agent数量 不受限
简介: docker安装kafka(wurstmeister)

本文记录一下docker中安装kafka集群的过程

命令不能使用报错,请检查空格,尤其第一个转行符号后面的空格

客户端连接9092

如果java(springboot)连接,需要配置advertised.port

  1. 使用docker-compose,因为本机还没有安装,然后又安装了一下,之前有python的环境,所以直接使用pip安装了,各位看官自行百度找到适合自己的安装方式,如果没有安装docker-compose的安装一下
sudo pip install --upgrade pip
sudo pip install docker-compose\n
  1. 创建一个kafka的文件目录,后续所有操作都在该目录,然后创建docker-compose.yml文件
mkdir /kafka
cd /kafka
vim docker-compose.yml
  1. docker-compose.yml文件内容如下
version: '2'
services:
  zookeeper:
    image: wurstmeister/zookeeper
    ports:
      - "2181:2181"
  kafka:
    image: wurstmeister/kafka:2.11-0.11.0.3
    ports:
      - "9092"
    environment:
      KAFKA_ADVERTISED_LISTENERS: PLAINTEXT://:9092
      KAFKA_LISTENERS: PLAINTEXT://:9092
      KAFKA_ZOOKEEPER_CONNECT: zookeeper:2181
    volumes:
      - /var/run/docker.sock:/var/run/docker.sock
  1. 本地拉取kafka镜像(wurstmeister/kafka)start数最多的
docker search kafka
docker pull wurstmeister/kafka
  1. 开始创建
# 切换到刚才创建docker-compsoe.yml文件的地
cd /kafka 
# 执行命令
docker-compose up -d
  1. 查看创建容器
docker ps
# 此处已经可以看到创建了一个kafka-zookeeper容器
  1. 查看kafka版本号
docker exec kafka_kafka_1 find / -name \*kafka_\* | head -1 | grep -o '\kafka[^\n]*'
  1. 查看zookeeper版本号
docker exec (zookeeper容器名称或者容器id) pwd
  1. 扩展broker
docker-compose scale kafka=4
  1. 查看创建的多个broker
docker ps
# 此处可以看到已经创建了4个
  1. 创建topic
docker exec kafka_kafka_1 \
kafka-topics.sh \
--create --topic topic001 \
--partitions 4 \
--zookeeper zookeeper:2181 \
--replication-factor 2
  1. 查看创建的topic(每个broker的容器id或者名称都可以)kafka_kafka_1即第一个容器名称
docker exec kafka_kafka_1 \
kafka-topics.sh --list \
--zookeeper zookeeper:2181 \
topic001
  1. 查看刚刚创建的topic的情况,borker和副本情况一目了然,代码一行一行输入
docker exec kafka_kafka_1 \     
kafka-topics.sh \
--describe \
--topic topic001 \
--zookeeper zookeeper:2181
  1. 创建消费者开始生产消息消费消息演示,此处还没有生产消息,所有没有任何显示
docker exec kafka_kafka_1 \
kafka-console-consumer.sh \
--topic topic001 \
--bootstrap-server kafka_kafka_1:9092,kafka_kafka_2:9092,kafka_kafka_3:9092,kafka_kafka_4:9092
  1. 生产者生产消息(新开一个窗口)
docker exec -it kafka_kafka_1 \
kafka-console-producer.sh \
--topic topic001 \
--broker-list kafka_kafka_1:9092,kafka_kafka_2:9092,kafka_kafka_3:9092,kafka_kafka_4:9092
  1. 在生产者窗口运行15的命令之后,随意输入几个字符串,即可在消费者端看到显示,到此,docker安装kafka就结束了。
  2. 感谢参考的博客
    参考链接:kafka的docker镜像使用
    docker镜像地址
  3. 送上docker-compose 开启关闭命令
#开启
docker-compose up -d
#关闭
docker-compose stop
目录
相关文章
|
4天前
|
时序数据库 Docker 容器
Docker安装InfluxDB
Docker安装InfluxDB
8 0
|
6天前
|
关系型数据库 MySQL 数据库
docker自定义安装mysql 5.7
docker自定义安装mysql 5.7
15 0
|
17天前
|
Linux Shell 开发工具
CentOS8中Docker安装及部署
CentOS8中Docker安装及部署
63 0
|
19天前
|
弹性计算 Serverless 数据库
ECS安装问题之docker安装如何解决
ECS(Elastic Compute Service,弹性计算服务)是云计算服务提供商提供的一种基础云服务,允许用户在云端获取和配置虚拟服务器。以下是ECS服务使用中的一些常见问题及其解答的合集:
|
25天前
|
关系型数据库 分布式数据库 PolarDB
PolarDB常见问题之安装gms时出现docker如何解决
PolarDB是阿里云推出的下一代关系型数据库,具有高性能、高可用性和弹性伸缩能力,适用于大规模数据处理场景。本汇总囊括了PolarDB使用中用户可能遭遇的一系列常见问题及解答,旨在为数据库管理员和开发者提供全面的问题指导,确保数据库平稳运行和优化使用体验。
|
27天前
|
Devops 开发工具 数据安全/隐私保护
Docker Swarm总结+CI/CD Devops、gitlab、sonarqube以及harbor的安装集成配置(3/5)
Docker Swarm总结+CI/CD Devops、gitlab、sonarqube以及harbor的安装集成配置(3/5)
41 0
|
27天前
|
NoSQL 关系型数据库 MySQL
Docker安装详细步骤及相关环境安装配置(mysql、jdk、redis、自己的私有仓库Gitlab 、C和C++环境以及Nginx服务代理)
Docker安装详细步骤及相关环境安装配置(mysql、jdk、redis、自己的私有仓库Gitlab 、C和C++环境以及Nginx服务代理)
176 0
|
28天前
|
NoSQL MongoDB Docker
docker安装MongoDB
docker安装MongoDB
21 0
|
30天前
|
负载均衡 应用服务中间件 nginx
|
1月前
|
消息中间件 Kafka Linux
Kafka【付诸实践 03】Offset Explorer Kafka 的终极 UI 工具安装+简单上手+关键特性测试(一篇学会使用 Offset Explorer)
【2月更文挑战第21天】Kafka【付诸实践 03】Offset Explorer Kafka 的终极 UI 工具安装+简单上手+关键特性测试(一篇学会使用 Offset Explorer)
143 2

热门文章

最新文章