1. #笔者版本 ZOOKEEPER_VERSION=3.4.13 //DockerVersion=18.03.1-ee-3
    2. #拉zookeeper镜像
    3. docker pull wurstmeister/zookeeper
    4. #笔者版本 KAFKA_VERSION=2.8.1 //SCALA_VERSION=2.13 //GLIBC_VERSION=2.31-r0
    5. #拉kafka镜像
    6. docker pull wurstmeister/kafka
    7. #启动zookeeper
    8. docker run -d --name zookeeper -p 2181:2181 -t wurstmeister/zookeeper
    9. #启动kafuka
    10. docker run -d --name kafka \
    11. -p 9092:9092 \
    12. -e KAFKA_BROKER_ID=0 \
    13. -e KAFKA_ZOOKEEPER_CONNECT=【你的ip】:2181 \
    14. -e KAFKA_ADVERTISED_LISTENERS=PLAINTEXT://【你的ip】:9092 \
    15. -e KAFKA_LISTENERS=PLAINTEXT://0.0.0.0:9092 wurstmeister/kafka
    17. #进入容器
    18. docker exec -it 【你的容器id】 /bin/bash
    19. cd opt/kafka/bin
    20. #单机方式：创建一个主题
    21. kafka-topics.sh --create --zookeeper 【你的ip】:2181 --replication-factor 1 --partitions 1 --topic mykafka
    22. #运行一个生产者
    23. kafka-console-producer.sh --broker-list localhost:9092 --topic mykafka
    24. #运行一个消费者
    25. kafka-console-consumer.sh --bootstrap-server 【你的ip】:9092 --topic mykafka --from-beginning
    26. #此处便完成了基本的测试环境
    29. #设置默认分区
    30. vi opt/kafka/config/server.properties
    31. 修改：num.partitions=2
    33. #指定分区数量
    34. ./kafka-topics.sh --zookeeper 【你的ip】:2181 --alter --partitions 3 --topic topicname

    安装Kafka可视化工具：kafkatool.com/download.html