zoukankan      html  css  js  c++  java
  • 十二 docker 安装kafka

    1: docker pull wurstmeister/zookeeper

    2: docker pull wurstmeister/kafka

    下面3和4需要在以admin的role在CMD里运行,用git bash不好使

    3: docker run -d --name zookeeper --publish 2181:2181 --volume /etc/localtime:/etc/localtime zookeeper:latest

     
    4: docker run -d --name kafka --publish 9092:9092 --link zookeeper --env KAFKA_ZOOKEEPER_CONNECT=zookeeper:2181
    --env KAFKA_ADVERTISED_HOST_NAME=kafka所在宿主机的IP --env KAFKA_ADVERTISED_PORT=9092 --volume /etc/localtime:/etc/localtime
    wurstmeister/kafka:latest
     
    4: 执行Docker ps,找到kafka的Container ID,进入容器内部:
      docker exec -it ${CONTAINER ID} /bin/bash  
     /

    5: 创建一个topic:(kafka的安装路径: opt/kafka)

    1
    bin/kafka-topics.sh --create --zookeeper zookeeper:2181 --replication-factor 1 --partitions 1 --topic mykafka 

    6: 运行一个消息生产者,指定topic为刚刚创建的主题

    1
    bin/kafka-console-producer.sh --broker-list localhost:9092 --topic mykafka 

    7: 运行一个消费者,指定同样的主题

    1
    bin/kafka-console-consumer.sh --bootstrap-server localhost:9092 --topic mykafka --from-beginning 
  • 相关阅读:
    ExpandoObject与DynamicObject的使用
    ManualResetEvent 线程通信
    CancellationTokenSource 取消任务
    SQL Server 每日一题--老二解析
    说说 C# 8 using 新特性
    SQL Server 每日一题--老二
    C#中的坑--浮点类型
    开胃菜解析
    开胃菜
    快速入门 Arrow 日期处理库
  • 原文地址:https://www.cnblogs.com/liufei1983/p/15706019.html
Copyright © 2011-2022 走看看