记快乐符号:
    利用docker搭建zookeeper 以及 kafa

    1. 官网: https://kafka.apache.org/documentation/
    3. 安装zookeeper
    5. docker run -it -p2888:2888 -p2181:2181 --name=zookeeper zookeeper
    7. 安装centos的Docker镜像
    9. docker run -it -p9092:9092 --name=kafka centos:7
    11. 以下操作保持在 我们启动的kafka容器中操作
    13. 我们更新一下软件列表
    14. dnf update
    16. 更完成后，我们再去下载vim
    17. dnf install vim
    19. 由于kafka需要java环境，我们需要安装openjdk
    20. dnf install java
    22. java -version
    24. 通过curl下载kafka
    25. https://mirrors.bfsu.edu.cn/apache/kafka/
    26. curl -O -L https://mirrors.tuna.tsinghua.edu.cn/apache/kafka/2.6.0/kafka_2.12-2.6.0.tgz
    28. tar -zvxf kafka_2.12-2.6.0.tgz
    30. 使用contro+p+q来退出docker 内部容器控制台，返回值宿主机控制台
    33. 我们要查看zookeeper的ip 那我们使用 
    34. docker inspect --format='{{.NetworkSettings.IPAddress}} CONTAINER ID
    36. docker inspect --format='{{.NetworkSettings.IPAddress}} 995242c5d83c
    38. qinghai@localhost software % docker inspect --format='{{.NetworkSettings.IPAddress}}' zookeeper 
    39. 172.17.0.2
    41. 那么我获取到的zookeeper的ip地址为：172.17.0.2
    43. 我们重新回到kafka容器内部
    44. docker exec -it kafka /bin/bash
    46. 进入kafka的安装目录后，我们进入bin目录中
    47. 进入kafka的config的路径中
    48. 编辑server.properties文件
    49. 将zookeeper.connect=localhost:2181更改为zookeeper.connect=172.17.0.2:2181
    50. 启动kafka 
    51. ./kafka-server-start.sh ../config/server.properties
    53. 上面的部分省略....
    54. [2020-09-09 13:59:16,767] INFO [KafkaServer id=0] started (kafka.server.KafkaServer)
    56. 此时，我们使用contro+p+q重新进入kafka容器中
    57. docker exec -it kafka /bin/bash
    59. 进入kafka的安装路径，在进入bin执行
    60. [root@0db103c94a5c bin]#
    61.  ./kafka-topics.sh --create --zookeeper 172.17.0.2:2181 --replication-factor 1 --partitions 1 --topic nanjolono
    62. 得到了结果，我们创建了一个名字为nanjolono的topic
    63. Created topic nanjolono.
    65. 查看创建的topic
    67. ./kafka-topics.sh --list --zookeeper 172.17.0.2:2181
    69. 发送一些消息
    71. [root@0db103c94a5c bin]# 
    72. ./kafka-console-producer.sh --broker-list localhost:9092 --topic nanjolono
    73. >
    75. 我们再次创建一个shell窗口
    76. 进入kafka容器中
    78. docker exec -it kafka /bin/bash 
    80. 进入kafka的安装目录，进入bin目录
    82. ./kafka-console-consumer.sh --bootstrap-server localhost:9092 --topic nanjolono --from-beginning 
    84. kafka-consumer-groups.sh --bootstrap-server localhost:9092 --describe --group my-group
    88. https://kafka.apache.org/documentation/
    91. 此时，我们在生产者控制台输入文字，消费者控制台能够成功接受到，就是成功啦！