集群管理

集群部署

Docker Compose

version: '3.8'
services:
  zookeeper:
    image: bitnami/zookeeper:3.9.1
    ports: ["2181:2181"]
  
  kafka:
    image: bitnami/kafka:3.7.0
    ports: ["9092:9092"]
    environment:
      KAFKA_ZOOKEEPER_CONNECT: zookeeper:2181
      KAFKA_ADVERTISED_LISTENERS: PLAINTEXT://localhost:9092

监控

# 查看集群状态
kafka-broker-api-versions.sh --bootstrap-server localhost:9092

# 查看主题详情
kafka-topics.sh --describe --topic my-topic \
  --bootstrap-server localhost:9092

# 查看消费者组
kafka-consumer-groups.sh --list \
  --bootstrap-server localhost:9092

运维命令

# 创建主题
kafka-topics.sh --create --topic my-topic \
  --partitions 3 --replication-factor 2 \
  --bootstrap-server localhost:9092

# 删除主题
kafka-topics.sh --delete --topic my-topic \
  --bootstrap-server localhost:9092

参考：https://kafka.apache.org/documentation/