1
2
3
4
5
6
7
8
9
10
11
12
13
14
15

version: '3'
services:
  zookeeper:
    image: 大专栏  Docker快速安装kafkalass="string">wurstmeister/zookeeper
    ports:
      - "2181:2181" 
  kafka:
    image: wurstmeister/kafka
    ports:
      - "9092:9092"
    environment:
      KAFKA_ADVERTISED_HOST_NAME: 192.168.153.152 # 宿主IP地址，此为我虚拟机地址
      KAFKA_ZOOKEEPER_CONNECT: zookeeper:2181
    volumes:
      - /var/run/docker.sock:/var/run/docker.sock

1
2
3
4
5
6
7
8
9
10
11
12

docker exec -it kafka_kafka_1 /bin/bash # 进入kafka终端

# 创建test主题，副本1，分区1
kafka-topics.sh --create --topic test --zookeeper kafka_zookeeper_1:2181 --replication-factor 1 --partitions 1

kafka-topics.sh --list --zookeeper kafka_zookeeper_1:2181 # 查看刚才创建的test分区

# 发布消息，输入几条消息后，按^C退出发布
kafka-console-producer.sh --topic=test --broker-list kafka_kafka_1:9092

# 接收消息
kafka-console-consumer.sh --bootstrap-server kafka_kafka_1:9092 --from-beginning --topic test