### 使用 Docker Compose 部署 Kafka 集群并启用用户名密码认证 为了实现这一目标，可以采用 Confluent 提供的镜像来简化设置过程。Confluent 是 Apache Kafka 的商业支持者之一，其官方提供的 Docker 映像包含了多种安全特性。 #### 准备工作 创建一个新的目录用于保存所有的配置文件和服务定义： ```bash mkdir kafka-cluster && cd kafka-cluster ``` 在此项目根目录下建立 `docker-compose.yml` 文件，该文件描述了服务之间的关系以及它们各自的环境变量和其他参数。 #### 编写 docker-compose.yml 文件 下面是一个简单的例子，展示了如何通过 Docker Compose 来部署单节点 Zookeeper 和多节点 Kafka 集群，并启用了 SASL/PLAIN 认证机制[^1]。 ```yaml version: '3' services: zookeeper: image: confluentinc/cp-zookeeper:latest environment: ZOOKEEPER_CLIENT_PORT: 2181 ZOOKEEPER_TICK_TIME: 2000 kafka1: image: confluentinc/cp-kafka:latest depends_on: - zookeeper ports: - "9092:9092" environment: KAFKA_BROKER_ID: 1 KAFICA_ZOOKEEPER_CONNECT: zookeeper:2181 ALLOW_PLAINTEXT_LISTENER: "no" KAFKA_ADVERTISED_LISTENERS: PLAINTEXT://kafka1:29092,SSL://kafka1:9093,SASL_PLAINTEXT://localhost:9092 KAFKA_LISTENER_SECURITY_PROTOCOL_MAP: PLAINTEXT:PLAINTEXT,SSL:SSL,SASL_PLAINTEXT:SASL_PLAINTEXT KAFKA_INTER_BROKER_LISTENER_NAME: SASL_PLAINTEXT KAFKA_SASL_ENABLED_MECHANISMS: PLAIN KAFKA_SASL_MECHANISM_INTER_BROKER_PROTOCOL: PLAIN KAFKA_AUTHORIZER_CLASS_NAME: kafka.security.auth.SimpleAclAuthorizer KAFKA_SUPER_USERS: User:admin;User:alice kafka2: image: confluentinc/cp-kafka:latest depends_on: - zookeeper ports: - "9093:9093" environment: KAFKA_BROKER_ID: 2 KAFICA_ZOOKEEPER_CONNECT: zookeeper:2181 ALLOW_PLAINTEXT_LISTENER: "no" KAFKA_ADVERTISED_LISTENERS: PLAINTEXT://kafka2:39092,SSL://kafka2:9094,SASL_PLAINTEXT://localhost:9093 KAFKA_LISTENER_SECURITY_PROTOCOL_MAP: PLAINTEXT:PLAINTEXT,SSL:SSL,SASL_PLAINTEXT:SASL_PLAINTEXT KAFKA_INTER_BROKER_LISTENER_NAME: SASL_PLAINTEXT KAFKA_SASL_ENABLED_MECHANISMS: PLAIN KAFKA_SASL_MECHANISM_INTER_BROKER_PROTOCOL: PLAIN KAFKA_AUTHORIZER_CLASS_NAME: kafka.security.auth.SimpleAclAuthorizer KAFKA_SUPER_USERS: User:admin;User:bob ``` 上述 YAML 文件中设置了两个 Kafka 节点 (`kafka1`, `kafka2`) 并指定了不同的端口映射以便在同一主机上运行多个实例。对于每个 Kafka 实例而言，都开启了三种监听器 (PLAINTEXT, SSL, SASL_PLAINTEXT)，其中特别强调的是 SASL_PLAINTEXT 方式的使用，它允许客户端连接时提供用户名和密码验证[^2]。 注意，在实际生产环境中应当避免直接暴露内部网络地址给外部访问；这里仅作为学习目的展示基本概念。 #### 启动集群 完成以上步骤之后就可以利用命令行工具启动整个集群了。由于已经编写好了 `docker-compose.yml` 文件，因此只需要执行以下指令即可让所有容器按照指定的方式自动构建并启动起来[^3]: ```bash docker-compose up -d ``` 这将会以后台模式启动所有服务并将控制权返回给终端窗口。 #### 测试连接 要测试是否成功启用了基于用户名密码的身份验证功能，则可以在本地机器或者其他能够访问到这些端口的地方尝试使用 kafkacat 或其他兼容的 Kafka 客户端来进行消息发送接收操作。记得在客户端配置里加入必要的 JAAS 设置以匹配服务器端的要求。