docker安装kafka集群

安装kafka集群需要以下步骤：

1. 安装docker和docker-compose（如果已经安装可以跳过此步）。

2. 创建一个kafka集群的docker-compose.yml文件。该文件包含了kafka集群的配置信息，可以参考以下模板：

version: '2'
services:
  zookeeper:
    image: wurstmeister/zookeeper
    ports:
      - "2181:2181"
  kafka1:
    image: wurstmeister/kafka
    ports:
      - "9091:9091"
    environment:
      KAFKA_ADVERTISED_HOST_NAME: {kafka1的ip地址}
      KAFKA_ZOOKEEPER_CONNECT: zookeeper:2181
      KAFKA_BROKER_ID: 1
      KAFKA_OFFSETS_TOPIC_REPLICATION_FACTOR: 1
  kafka2:
    image: wurstmeister/kafka
    ports:
      - "9092:9092"
    environment:
      KAFKA_ADVERTISED_HOST_NAME: {kafka2的ip地址}
      KAFKA_ZOOKEEPER_CONNECT: zookeeper:2181
      KAFKA_BROKER_ID: 2
      KAFKA_OFFSETS_TOPIC_REPLICATION_FACTOR: 1

3. 在命令行中进入到包含docker-compose.yml文件的目录，执行以下命令启动kafka集群：

docker-compose up -d

4. 验证kafka集群是否正常运行。可以通过在kafka1或kafka2容器中执行以下命令来创建一个测试主题：

docker exec -it {kafka容器名称} bash

kafka-topics.sh --create --topic test-topic --partitions 3 --replication-factor 2 --zookeeper zookeeper:2181

kafka-console-producer.sh --topic test-topic --broker-list kafka1:9091,kafka2:9092

kafka-console-consumer.sh --topic test-topic --bootstrap-server kafka1:9091,kafka2:9092 --from-beginning

以上命令中，kafka容器名称可以通过docker ps命令查看。

5. 如果测试主题创建并且可以正常发送和接收消息，则说明kafka集群已经成功安装并运行。