栏目分类:
子分类:
返回
名师互学网用户登录
快速导航关闭
当前搜索
当前分类
子分类
实用工具
热门搜索
名师互学网 > IT > 前沿技术 > 大数据 > 大数据系统

docker 安装配置kafka服务端

docker 安装配置kafka服务端

1. 拉取相关docker镜像

docker pull wurstmeister/kafka:latest
docker pull wurstmeister/zookeeper:latest

2. 安装docker-compose

sudo curl -L "https://github.com/docker/compose/releases/download/1.24.1/docker-compose-$(uname -s)-$(uname -m)" -o /usr/local/bin/docker-compose

修改docker-compose权限

sudo chmod +x /usr/local/bin/docker-compose

3. 启动kafka的docker-compose.yaml配置文件

根据自己的机器IP修改yaml文件中的KAFKA_ADVERTISED_HOST_NAME字段值

version: '2'
services:

  zookeeper:
    image: wurstmeister/zookeeper
    ports:
      - "2181:2181"
  kafka:
    image: wurstmeister/kafka
    depends_on: [ zookeeper ]
    ports:
      - "9092:9092"
    environment:
      KAFKA_ADVERTISED_HOST_NAME: 10.10.113.75
      KAFKA_CREATE_TOPICS: "test:1:1"
      KAFKA_ZOOKEEPER_CONNECT: zookeeper:2181
    volumes:
      - /home/deep/share2/kafka/docker.sock:/var/run/docker.sock

4. 启动kafka服务

docker-compose up

5. 测试

#进入kafka容器
docker exec -it ${ConTAINER ID} /bin/bash
cd opt/bin
#单机方式:创建一个主题
bin/kafka-topics.sh --create --zookeeper zookeeper:2181 --replication-factor 1 --partitions 1 --topic mykafka
#运行一个生产者
bin/kafka-console-producer.sh --broker-list localhost:9092 --topic mykafka
#运行一个消费者
bin/kafka-console-consumer.sh --zookeeper zookeeper:2181 --topic mykafka --from-beginning

转载请注明:文章转载自 www.mshxw.com
本文地址:https://www.mshxw.com/it/671481.html
我们一直用心在做
关于我们 文章归档 网站地图 联系我们

版权所有 (c)2021-2022 MSHXW.COM

ICP备案号:晋ICP备2021003244-6号