zoukankan      html  css  js  c++  java
  • Docker部署Kafka


    Docker部署Kafka

    单机部署:

    实验环境:

    192.168.5.185  kafka1
    192.168.5.185  kafka2
    192.168.5.185  kafka3
    192.168.5.185  zookeeper
    192.168.5.185  kafka-manager

    1.下载镜像

    下载zookeeper镜像:

    [root@localhost ~]#  docker pull wurstmeister/zookeeper

    下载Kafka镜像:

    [root@localhost ~]#  docker pull wurstmeister/kafka

    下载kafka-manager镜像:

    [root@localhost ~]#  docker pull sheepkiller/kafka-manager

    2.启动容器

    启动zookeeper容器:

    [root@localhost ~]#  docker run -d --name zookeeper -p 2181:2181 -t wurstmeister/zookeeper

    启动kafka容器(集群方式):

    Kafka节点1:

    [root@localhost ~]#  docker run -it -d --name kafka1 -p 9092:9092 -e KAFKA_BROKER_ID=0 -e KAFKA_ZOOKEEPER_CONNECT=192.168.5.185:2181 -e KAFKA_ADVERTISED_LISTENERS=PLAINTEXT://192.168.5.185:9092 -e KAFKA_LISTENERS=PLAINTEXT://0.0.0.0:9092 -t wurstmeister/kafka

    Kafka节点2:

    [root@localhost ~]#  docker run -it -d --name kafka2 -p 9093:9093 -e KAFKA_BROKER_ID=1 -e KAFKA_ZOOKEEPER_CONNECT=192.168.5.185:2181 -e KAFKA_ADVERTISED_LISTENERS=PLAINTEXT://192.168.5.185:9093 -e KAFKA_LISTENERS=PLAINTEXT://0.0.0.0:9093 -t wurstmeister/kafka

    Kafka节点3:

    [root@localhost ~]#  docker run -it -d --name kafka3 -p 9094:9094 -e KAFKA_BROKER_ID=2 -e KAFKA_ZOOKEEPER_CONNECT=192.168.5.185:2181 -e KAFKA_ADVERTISED_LISTENERS=PLAINTEXT://192.168.5.185:9094 -e KAFKA_LISTENERS=PLAINTEXT://0.0.0.0:9094 -t wurstmeister/kafka

    启动Kafka-manager容器:

    [root@localhost ~]#  docker run -it -d --restart=always --name=kafka-manager -p 9000:9000 -e ZK_HOSTS=192.168.5.185:2181 sheepkiller/kafka-manager

    3.检查端口

    [root@localhost ~]#  netstat -anl | grep 2181
    [root@localhost ~]#  netstat -anl | grep 9092
    [root@localhost ~]#  netstat -anl | grep 9093
    [root@localhost ~]#  netstat -anl | grep 9094

    4.访问web

    http://192.168.5.185:9000

  • 相关阅读:
    iOS软件版本更新思路
    Xcode里-ObjC, -all_load, -force_load
    NSFileManager
    [Android问答] px、dp和sp,这些单位有什么区别?
    annot refer to a non-final variable * inside an inner class defined in a different method"错误解析
    android Handler post sendMessage
    谈layout_gravity和gravity的用法
    Android LayoutInflater详解
    Android中pendingIntent的深入理解
    Intent和PendingIntent的区别
  • 原文地址:https://www.cnblogs.com/haoee/p/14638064.html
Copyright © 2011-2022 走看看