• 技术文章 >后端开发 >Golang

    介绍kafka和zookeeper是如何安装的

    藏色散人藏色散人2021-11-23 15:23:50转载84
    本文由go语言教程栏目给大家介绍kafka和zookeeper是如何安装的 ,希望对需要的朋友有所帮助!

    kafka和zookeeper安装

    编写 compose

      zookeeper:
        image: wurstmeister/zookeeper
        ports:
          - "2181:2181"
      kafka:
        image: wurstmeister/kafka
        volumes:
            - ./data/etc/localtime:/etc/localtime
            - ./data/var/run/docker.sock:/var/run/docker.sock
        ports:
          - "9092:9092"
        environment:
          KAFKA_ADVERTISED_HOST_NAME: 192.168.110.147   ## 宿主机IP
          KAFKA_ZOOKEEPER_CONNECT: zookeeper:2181
          KAFKA_ADVERTISED_PORT: 9092
      kafka-manager:
        image: sheepkiller/kafka-manager
        environment:
            ZK_HOSTS:  192.168.110.147                  ## zookeeper地址
        ports:
          - "9091:9000"                                 # 宿主机port:container_port

    开始安装

    luwei@luweideMacBook-Pro-2 lnmp % docker-compose up -d zookeeper
    Pulling zookeeper (wurstmeister/zookeeper:)...
    latest: Pulling from wurstmeister/zookeeper
    a3ed95caeb02: Pull complete
    ef38b711a50f: Pull complete
    e057c74597c7: Pull complete
    666c214f6385: Pull complete
    c3d6a96f1ffc: Pull complete
    3fe26a83e0ca: Pull complete
    3d3a7dd3a3b1: Pull complete
    f8cc938abe5f: Pull complete
    9978b75f7a58: Pull complete
    4d4dbcc8f8cc: Pull complete
    8b130a9baa49: Pull complete
    6b9611650a73: Pull complete
    5df5aac51927: Pull complete
    76eea4448d9b: Pull complete
    8b66990876c6: Pull complete
    f0dd38204b6f: Pull complete
    Digest: sha256:7a7fd44a72104bfbd24a77844bad5fabc86485b036f988ea927d1780782a6680
    Status: Downloaded newer image for wurstmeister/zookeeper:latest
    Creating lnmp_zookeeper_1 ... done
    luwei@luweideMacBook-Pro-2 lnmp % docker-compose up -d kafka
    lnmp_kafka_1 is up-to-date
    luwei@luweideMacBook-Pro-2 lnmp % docker-compose up -d kafka        
    Starting lnmp_kafka_1 ... done

    查看安装结果

    luwei@luweideMacBook-Pro-2 ~ % docker ps
    CONTAINER ID   IMAGE                                                  COMMAND                  CREATED          STATUS                            PORTS                                                NAMES
    28a2a3b33856   sheepkiller/kafka-manager                              "./start-kafka-manag…"   3 minutes ago    Up 3 minutes                      0.0.0.0:9091->9000/tcp                               lnmp_kafka-manager_1
    d6ae300116f3   wurstmeister/zookeeper                                 "/bin/sh -c '/usr/sb…"   9 minutes ago    Up 8 minutes                      22/tcp, 2888/tcp, 3888/tcp, 0.0.0.0:2181->2181/tcp   lnmp_zookeeper_1
    c9de041d5ace   wurstmeister/kafka                                     "start-kafka.sh"         15 minutes ago   Up 4 seconds                      0.0.0.0:9092->9092/tcp                               lnmp_kafka_1
    92b5e1563062   mysql:5.7.16                                           "docker-entrypoint.s…"   2 weeks ago      Up 6 hours                        0.0.0.0:3307->3306/tcp                               my_mysql57
    29f0b85f1284   registry.cn-hangzhou.aliyuncs.com/helowin/oracle_11g   "/bin/sh -c '/home/o…"   3 weeks ago      Up 6 hours                        0.0.0.0:1521->1521/tcp                               oracle
    89c169b8bd14   nginx:alpine                                           "/docker-entrypoint.…"   4 weeks ago      Up 6 hours (healthy)              0.0.0.0:81->80/tcp, 0.0.0.0:444->443/tcp             nginx
    e0e4fa4bf177   lnmp_php72                                             "entrypoint php-fpm"     4 weeks ago      Up 6 hours (healthy)              9000-9001/tcp                                        php72
    a1ddf67627cd   lnmp_php56                                             "entrypoint php-fpm"     4 weeks ago      Up 6 hours (healthy)              9000/tcp                                             php56
    324aa6c8b071   lnmp_php71                                             "entrypoint php-fpm"     4 weeks ago      Up 6 hours (healthy)              9000/tcp                                             php71
    4fd5d2ce7612   mongo:4.4.0                                            "docker-entrypoint.s…"   4 weeks ago      Up 6 hours                        0.0.0.0:27018->27017/tcp                             mongo4.4
    f212f81e0546   redis:4-alpine                                         "docker-entrypoint.s…"   4 weeks ago      Up 6 hours (healthy)              0.0.0.0:6379->6379/tcp                               redis
    e42962aa16c8   mysql:5.6                                              "docker-entrypoint.s…"   4 weeks ago      Restarting (137) 50 seconds ago                                                        mysql
    luwei@luweideMacBook-Pro-2 ~ %

    连接 kafka 容器

    luwei@luweideMacBook-Pro-2 ~ % docker exec -it lnmp_kafka_1 /bin/bash
    bash-5.1#

    创建 topic

    bash-5.1# find / -name kafka-topics.sh
    /opt/kafka_2.13-2.7.1/bin/kafka-topics.sh
    bash-5.1# /opt/kafka_2.13-2.7.1/bin/kafka-topics.sh --create --zookeeper 192.168.110.147:2181 --replication-factor 1  --partitions 1 --topic test
    Created topic test.
    bash-5.1#

    查看创建的主题

    bash-5.1# /opt/kafka_2.13-2.7.1/bin/kafka-topics.sh --list --zookeeper 192.168.110.147:2181
    test
    bash-5.1#

    启动生产者

    bash-5.1# find / -name kafka-console-producer.sh
    /opt/kafka_2.13-2.7.1/bin/kafka-console-producer.sh
    bash-5.1# /opt/kafka_2.13-2.7.1/bin/kafka-console-producer.sh --broker-list 192.168.110.147:9092 --topic mykafka
    >hello donglei
    [2021-11-22 08:05:19,506] WARN [Producer clientId=console-producer] Error while fetching metadata with correlation id 3 : {mykafka=LEADER_NOT_AVAILABLE} (org.apache.kafka.clients.NetworkClient)
    >

    启动消费者

    bash-5.1# /opt/kafka_2.13-2.7.1/bin/kafka-console-consumer.sh --bootstrap-server 192.168.110.147:9092 --topic mykafka --from-beginning
    hello donglei

    以上就是介绍kafka和zookeeper是如何安装的的详细内容,更多请关注php中文网其它相关文章!

    声明:本文转载于:learnku,如有侵犯,请联系admin@php.cn删除
    专题推荐:kafka zookeeper
    上一篇:结合实例讲解Go struct实例化和赋值 下一篇:经验分享:golang与c语言是如何相互调用!
    php中文网线上培训班

    相关文章推荐

    • 享受PHP与Go的强大合体【RoadRunner】的乐趣!• embed是啥?Go怎么用它加载静态文件?• 一文解析Go中Int的最大数值• 结合实例讲解Go struct实例化和赋值

    全部评论我要评论

  • 取消发布评论发送
  • 1/1

    PHP中文网