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

Liunx下Docker安装kafka

Liunx下Docker安装kafka

Liunx下Docker安装kafka
  1. 拉取zookeeper、kafka镜像

    • docker pull wurstmeister/zookeeper
      docker pull wurstmeister/kafka
      
  2. 先启动zookeeper

    • docker run -d --name zookeeper -p 2181:2181 -v /etc/localtime:/etc/localtime wurstmeister/zookeeper
      
      #-v /etc/localtime:/etc/localtime 容器时间同步虚拟机的时间
      
  3. 再启动kafka(单机模式)

    • docker run -d --name kafka 
      -p 9092:9092 
      -e KAFKA_BROKER_ID=0 
      -e KAFKA_ZOOKEEPER_ConNECT=服务器ip:2181 
      -e KAFKA_ADVERTISED_LISTENERS=PLAINTEXT://服务器ip:9092 
      -e KAFKA_LISTENERS=PLAINTEXT://0.0.0.0:9092 
      -v /etc/localtime:/etc/localtime 
      wurstmeister/kafka
      
      #-e KAFKA_BROKER_ID=0  在kafka集群中,每个kafka都有一个BROKER_ID来区分自己
      #-e KAFKA_ZOOKEEPER_ConNECT=服务器ip:2181/kafka 配置zookeeper管理kafka的路径服务器ip:2181/kafka
      #-e KAFKA_ADVERTISED_LISTENERS=PLAINTEXT://服务器ip:9092  把kafka的地址端口注册给zookeeper
      #-e KAFKA_LISTENERS=PLAINTEXT://0.0.0.0:9092 配置kafka的监听端口
      #-v /etc/localtime:/etc/localtime 容器时间同步虚拟机的时间
      
  4. 测试是否启动成功

    • #进入容器
      docker exec -it kafka /bin/sh
      
      #进入kafika/bin
      cd opt/kafka_2.13-2.8.1/
      
      #运行kafka生产者发送消息
      ./kafka-console-producer.sh --broker-list localhost:9092 --topic sun
      
      #发送信息
      test kafka
      
      #ctrl + c 退出发送信息
      
      #运行kafka消费者接收消息
      ./kafka-console-consumer.sh --bootstrap-server localhost:9092 --topic sun --from-beginning
      
转载请注明:文章转载自 www.mshxw.com
本文地址:https://www.mshxw.com/it/687475.html
我们一直用心在做
关于我们 文章归档 网站地图 联系我们

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

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