• 启动 Kafka
• 疑问

启动 Kafka

启动单机多分区 Kafka

version: "3.8"

services:
  zookeeper:
    image: wurstmeister/zookeeper:3.4.6
    container_name: zookeeper
    ports:
      - "2181:2181"

  kafka:
    image: wurstmeister/kafka:2.13-2.8.1
    container_name: kafka
    ports:
      - "9092:9092"
    environment:
      KAFKA_BROKER_ID: 1
      KAFKA_ZOOKEEPER_CONNECT: zookeeper:2181
      KAFKA_ADVERTISED_LISTENERS: PLAINTEXT://localhost:9092
      KAFKA_LISTENERS: PLAINTEXT://0.0.0.0:9092
      # 创建一个3分区的topic <topic_name>:<partition_count>:<replication_factor>
      KAFKA_CREATE_TOPICS: "order_events:3:1"
    volumes:
      - /var/run/docker.sock:/var/run/docker.sock

启动和关闭

docker compose up -d

docker compose down

疑问

• Kafka 2.x 版本仍依赖 Zookeeper 做 ...
• auto.offset.reset 策略

kafka-console-consumer.sh \
  --bootstrap-server localhost:9092 \
  --topic order_events \
  --group new-group \
  --from-beginning