1. Kafka与Docker的黄金组合三年前我第一次在生产环境部署Kafka时整整折腾了两天。从Zookeeper集群配置到Broker参数调优各种依赖冲突和网络配置问题层出不穷。直到发现Docker这个神器原本复杂的分布式系统部署变得像搭积木一样简单。今天我就把多年实战积累的Docker化Kafka部署方案完整分享出来包含那些官方文档里不会告诉你的调优参数和避坑指南。这种容器化部署方式特别适合以下场景开发测试环境快速搭建需要频繁创建销毁的临时环境资源有限的本地开发机需要标准化部署的生产环境2. 环境准备与工具选型2.1 基础环境配置建议使用Linux系统Ubuntu 20.04或CentOS 7我这里以Ubuntu 22.04为例。首先确保已安装最新版Docker和Docker Compose# 卸载旧版本 sudo apt-get remove docker docker-engine docker.io containerd runc # 安装依赖 sudo apt-get update sudo apt-get install \ ca-certificates \ curl \ gnupg \ lsb-release # 添加Docker官方GPG密钥 sudo mkdir -p /etc/apt/keyrings curl -fsSL https://download.docker.com/linux/ubuntu/gpg | sudo gpg --dearmor -o /etc/apt/keyrings/docker.gpg # 设置稳定版仓库 echo \ deb [arch$(dpkg --print-architecture) signed-by/etc/apt/keyrings/docker.gpg] https://download.docker.com/linux/ubuntu \ $(lsb_release -cs) stable | sudo tee /etc/apt/sources.list.d/docker.list /dev/null # 安装Docker引擎 sudo apt-get update sudo apt-get install docker-ce docker-ce-cli containerd.io docker-compose-plugin # 验证安装 sudo docker run hello-world重要提示生产环境务必配置docker用户组并设置权限避免直接使用root操作sudo groupadd docker sudo usermod -aG docker $USER newgrp docker2.2 镜像版本选择策略经过多次测试验证推荐使用以下镜像组合组件官方镜像推荐版本备注Zookeeperbitnami/zookeeper3.8.0稳定版兼容性好Kafkabitnami/kafka3.3.1支持最新协议管理工具obsidiandynamics/kafdrop4.0.0轻量级Web UI版本选择需要考虑生产环境建议使用固定版本号避免latest标签Kafka与Zookeeper版本需兼容3.3.x Kafka建议搭配3.8.x Zookeeper资源占用bitnami镜像比confluent官方镜像更轻量3. 单节点快速部署方案3.1 docker-compose编排文件创建docker-compose.yml文件version: 3.8 services: zookeeper: image: bitnami/zookeeper:3.8.0 container_name: zookeeper ports: - 2181:2181 environment: - ALLOW_ANONYMOUS_LOGINyes volumes: - zookeeper_data:/bitnami networks: - kafka-net kafka: image: bitnami/kafka:3.3.1 container_name: kafka ports: - 9092:9092 environment: - KAFKA_CFG_ZOOKEEPER_CONNECTzookeeper:2181 - ALLOW_PLAINTEXT_LISTENERyes - KAFKA_CFG_ADVERTISED_LISTENERSPLAINTEXT://localhost:9092 volumes: - kafka_data:/bitnami depends_on: - zookeeper networks: - kafka-net kafdrop: image: obsidiandynamics/kafdrop:4.0.0 container_name: kafdrop ports: - 9000:9000 environment: - KAFKA_BROKERCONNECTkafka:9092 - JVM_OPTS-Xms32M -Xmx64M depends_on: - kafka networks: - kafka-net volumes: zookeeper_data: driver: local kafka_data: driver: local networks: kafka-net: driver: bridge3.2 关键参数解析网络配置使用自定义bridge网络(kafka-net)实现容器间通信对外暴露端口9092Kafka broker端口9000Kafdrop管理界面数据持久化通过named volume实现数据持久化生产环境建议改为bind mount指定具体路径环境变量KAFKA_CFG_ADVERTISED_LISTENERS客户端连接地址ALLOW_PLAINTEXT_LISTENER允许明文传输仅限测试启动服务docker-compose up -d访问Kafdrop管理界面 http://localhost:90004. 生产级集群部署方案4.1 多节点集群配置修改后的docker-compose.ymlversion: 3.8 services: zookeeper: image: bitnami/zookeeper:3.8.0 deploy: replicas: 3 environment: - ZOO_SERVER_ID1 - ZOO_SERVERS0.0.0.0:2888:3888;zookeeper2:2888:3888;zookeeper3:2888:3888 - ALLOW_ANONYMOUS_LOGINyes volumes: - zk_data1:/bitnami networks: - kafka-net zookeeper2: image: bitnami/zookeeper:3.8.0 environment: - ZOO_SERVER_ID2 - ZOO_SERVERSzookeeper:2888:3888;0.0.0.0:2888:3888;zookeeper3:2888:3888 - ALLOW_ANONYMOUS_LOGINyes volumes: - zk_data2:/bitnami networks: - kafka-net zookeeper3: image: bitnami/zookeeper:3.8.0 environment: - ZOO_SERVER_ID3 - ZOO_SERVERSzookeeper:2888:3888;zookeeper2:2888:3888;0.0.0.0:2888:3888 - ALLOW_ANONYMOUS_LOGINyes volumes: - zk_data3:/bitnami networks: - kafka-net kafka1: image: bitnami/kafka:3.3.1 environment: - KAFKA_CFG_ZOOKEEPER_CONNECTzookeeper:2181,zookeeper2:2181,zookeeper3:2181 - KAFKA_CFG_BROKER_ID1 - KAFKA_CFG_LISTENER_SECURITY_PROTOCOL_MAPINTERNAL:PLAINTEXT,EXTERNAL:PLAINTEXT - KAFKA_CFG_LISTENERSINTERNAL://:29092,EXTERNAL://:9092 - KAFKA_CFG_ADVERTISED_LISTENERSINTERNAL://kafka1:29092,EXTERNAL://${HOST_IP}:9092 - KAFKA_CFG_INTER_BROKER_LISTENER_NAMEINTERNAL volumes: - kafka_data1:/bitnami depends_on: - zookeeper - zookeeper2 - zookeeper3 networks: - kafka-net # kafka2/kafka3配置类似...4.2 关键优化参数Zookeeper集群奇数节点数量3/5/7每节点需唯一SERVER_ID2888端口用于follower连接leader3888端口用于选举通信Kafka配置environment: - KAFKA_CFG_NUM_PARTITIONS3 # 默认分区数 - KAFKA_CFG_DEFAULT_REPLICATION_FACTOR2 # 默认副本数 - KAFKA_CFG_LOG_RETENTION_HOURS168 # 日志保留7天 - KAFKA_CFG_AUTO_CREATE_TOPICS_ENABLEfalse # 禁用自动创建topic资源限制deploy: resources: limits: cpus: 2 memory: 2G reservations: memory: 1G5. 运维监控与故障排查5.1 健康检查配置为每个服务添加健康检查healthcheck: test: [CMD-SHELL, kafka-topics.sh --bootstrap-server localhost:9092 --list] interval: 30s timeout: 10s retries: 35.2 常见问题处理启动超时问题# 查看容器日志 docker logs -f kafka1 # 常见错误Zookeeper连接失败 # 解决方案增加depends_on条件检查 healthcheck: test: [CMD-SHELL, zkServer.sh status]磁盘空间不足# 修改日志保留策略 environment: - KAFKA_CFG_LOG_RETENTION_BYTES1073741824 # 1GB - KAFKA_CFG_LOG_SEGMENT_BYTES268435456 # 256MB/段性能调优参数environment: - KAFKA_CFG_NUM_IO_THREADS8 - KAFKA_CFG_NUM_NETWORK_THREADS3 - KAFKA_CFG_NUM_RECOVERY_THREADS_PER_DATA_DIR15.3 监控方案Prometheus监控kafka: environment: - KAFKA_CFG_METRICS_ENABLEDtrue - KAFKA_CFG_METRICS_REPORTERSio.confluent.metrics.reporter.ConfluentMetricsReporter日志收集# 查看实时日志 docker-compose logs -f kafka # 生产环境建议配置ELK logging: driver: json-file options: max-size: 10m max-file: 36. 安全加固方案6.1 认证配置SASL/SCRAM认证environment: - KAFKA_CFG_SASL_ENABLED_MECHANISMSSCRAM-SHA-256 - KAFKA_CFG_LISTENER_SECURITY_PROTOCOL_MAPINTERNAL:SASL_PLAINTEXT - KAFKA_CLIENT_USERSadmin,user - KAFKA_CLIENT_PASSWORDSpassword123,user123SSL加密# 生成证书 openssl req -new -x509 -keyout kafka.key -out kafka.crt \ -days 365 -nodes -subj /CNkafka # 配置docker-compose volumes: - ./ssl:/opt/kafka/secrets environment: - KAFKA_CFG_SSL_KEYSTORE_LOCATION/opt/kafka/secrets/kafka.keystore.jks - KAFKA_CFG_SSL_TRUSTSTORE_LOCATION/opt/kafka/secrets/kafka.truststore.jks6.2 网络隔离自定义网络配置networks: kafka-net: driver: bridge ipam: config: - subnet: 172.28.0.0/16防火墙规则# 只允许特定IP访问 iptables -A DOCKER -p tcp --dport 9092 -s 192.168.1.0/24 -j ACCEPT iptables -A DOCKER -p tcp --dport 9092 -j DROP7. 性能压测与优化7.1 基准测试使用kafka-producer-perf-test工具docker exec -it kafka1 bash # 生产者测试 kafka-producer-perf-test \ --topic benchmark \ --num-records 1000000 \ --record-size 1000 \ --throughput -1 \ --producer-props \ bootstrap.serverskafka1:9092 \ acksall \ batch.size16384 # 消费者测试 kafka-consumer-perf-test \ --topic benchmark \ --messages 1000000 \ --bootstrap-server kafka1:90927.2 调优参数对照表参数名默认值推荐值说明num.io.threads816磁盘IO线程数num.network.threads38网络线程数log.flush.interval.messages100005000刷盘消息间隔socket.send.buffer.bytes102400409600发送缓冲区大小log.retention.check.interval.ms30000060000日志清理检查频率7.3 资源监控指标关键指标Under Replicated PartitionsRequest Queue SizeNetwork Processor Avg Idle Percent监控命令# 查看topic详情 docker exec kafka1 kafka-topics --describe \ --bootstrap-server kafka1:9092 # 查看消费者组 docker exec kafka1 kafka-consumer-groups --list \ --bootstrap-server kafka1:90928. 高级功能扩展8.1 Schema Registry集成schema-registry: image: confluentinc/cp-schema-registry:7.3.0 ports: - 8081:8081 environment: - SCHEMA_REGISTRY_HOST_NAMEschema-registry - SCHEMA_REGISTRY_KAFKASTORE_BOOTSTRAP_SERVERSkafka1:9092,kafka2:9092 depends_on: - kafka1 - kafka28.2 Kafka Connect配置kafka-connect: image: confluentinc/cp-kafka-connect:7.3.0 ports: - 8083:8083 environment: - CONNECT_BOOTSTRAP_SERVERSkafka1:9092,kafka2:9092 - CONNECT_GROUP_IDconnect-cluster - CONNECT_CONFIG_STORAGE_TOPICconnect-configs - CONNECT_OFFSET_STORAGE_TOPICconnect-offsets volumes: - ./connectors:/etc/kafka-connect/plugins8.3 多租户隔离方案网络隔离networks: tenant1-net: driver: bridge tenant2-net: driver: bridge资源限制deploy: resources: limits: cpus: 1 memory: 1GACL配置docker exec kafka1 kafka-acls --add \ --allow-principal User:tenant1 \ --operation Read --topic tenant1-* \ --bootstrap-server kafka1:90929. 实际案例订单处理系统9.1 拓扑结构设计订单服务 → (orders topic) → Kafka → → 支付服务(消费组1) → 库存服务(消费组2) → 分析服务(消费组3)9.2 关键配置environment: - KAFKA_CFG_NUM_PARTITIONS6 # 按业务量预估 - KAFKA_CFG_DEFAULT_REPLICATION_FACTOR3 - KAFKA_CFG_MIN_INSYNC_REPLICAS2 - KAFKA_CFG_MESSAGE_MAX_BYTES10485760 # 10MB大消息支持9.3 消费者重试策略// Spring Kafka配置示例 Bean public ConcurrentKafkaListenerContainerFactoryString, String kafkaListenerContainerFactory() { ConcurrentKafkaListenerContainerFactoryString, String factory new ConcurrentKafkaListenerContainerFactory(); factory.setConsumerFactory(consumerFactory()); // 重试策略 factory.setRetryTemplate(retryTemplate()); // 死信队列配置 factory.setRecoveryCallback(context - { Message? message (Message?) context.getAttribute(record); // 发送到死信队列 kafkaTemplate.send(orders.DLT, message.getPayload()); return null; }); return factory; }10. 版本升级与迁移10.1 滚动升级步骤逐个停止Kafka broker更新镜像版本重启并验证重复直到所有节点升级# 检查版本兼容性 docker exec kafka1 kafka-broker-api-versions \ --bootstrap-server kafka1:909210.2 数据迁移方案MirrorMaker2工具docker run confluentinc/cp-kafka:7.3.0 \ /usr/bin/connect-mirror-maker \ /etc/kafka/connect-mirror-maker.properties迁移检查清单验证topic配置一致性检查ACL权限监控消费者偏移量11. 灾备与高可用11.1 跨机房部署kafka: environment: - KAFKA_CFG_ADVERTISED_LISTENERSINTERNAL://kafka1:29092,EXTERNAL_DC1://dc1.example.com:9092,EXTERNAL_DC2://dc2.example.com:909211.2 备份恢复方案元数据备份# 导出topic配置 docker exec zookeeper1 zkCli.sh ls /config/topics数据备份# 使用kafka-dump-log工具 docker exec kafka1 kafka-dump-log \ --files /bitnami/kafka/data/test-0/00000000000000000000.log12. 最佳实践总结分区设计原则每个分区独立顺序保证分区数最大消费者数避免超过10,000分区/broker生产者配置acksall retriesMAX_INT max.in.flight.requests.per.connection1 enable.idempotencetrue消费者配置auto.offset.resetlatest enable.auto.commitfalse fetch.max.bytes52428800 max.poll.records500硬件建议优先考虑磁盘I/O性能建议SSD存储内存配置每百万消息/s约2GB在最后的生产实践中我发现合理设置log.retention.bytes比单纯依赖时间保留更可靠。曾经因为节假日流量激增导致磁盘爆满后来改为大小和时间双重限制才彻底解决问题。另外建议至少每季度执行一次broker滚动重启可以预防很多隐性问题。
1. Kafka与Docker的黄金组合三年前我第一次在生产环境部署Kafka时整整折腾了两天。从Zookeeper集群配置到Broker参数调优各种依赖冲突和网络配置问题层出不穷。直到发现Docker这个神器原本复杂的分布式系统部署变得像搭积木一样简单。今天我就把多年实战积累的Docker化Kafka部署方案完整分享出来包含那些官方文档里不会告诉你的调优参数和避坑指南。这种容器化部署方式特别适合以下场景开发测试环境快速搭建需要频繁创建销毁的临时环境资源有限的本地开发机需要标准化部署的生产环境2. 环境准备与工具选型2.1 基础环境配置建议使用Linux系统Ubuntu 20.04或CentOS 7我这里以Ubuntu 22.04为例。首先确保已安装最新版Docker和Docker Compose# 卸载旧版本 sudo apt-get remove docker docker-engine docker.io containerd runc # 安装依赖 sudo apt-get update sudo apt-get install \ ca-certificates \ curl \ gnupg \ lsb-release # 添加Docker官方GPG密钥 sudo mkdir -p /etc/apt/keyrings curl -fsSL https://download.docker.com/linux/ubuntu/gpg | sudo gpg --dearmor -o /etc/apt/keyrings/docker.gpg # 设置稳定版仓库 echo \ deb [arch$(dpkg --print-architecture) signed-by/etc/apt/keyrings/docker.gpg] https://download.docker.com/linux/ubuntu \ $(lsb_release -cs) stable | sudo tee /etc/apt/sources.list.d/docker.list /dev/null # 安装Docker引擎 sudo apt-get update sudo apt-get install docker-ce docker-ce-cli containerd.io docker-compose-plugin # 验证安装 sudo docker run hello-world重要提示生产环境务必配置docker用户组并设置权限避免直接使用root操作sudo groupadd docker sudo usermod -aG docker $USER newgrp docker2.2 镜像版本选择策略经过多次测试验证推荐使用以下镜像组合组件官方镜像推荐版本备注Zookeeperbitnami/zookeeper3.8.0稳定版兼容性好Kafkabitnami/kafka3.3.1支持最新协议管理工具obsidiandynamics/kafdrop4.0.0轻量级Web UI版本选择需要考虑生产环境建议使用固定版本号避免latest标签Kafka与Zookeeper版本需兼容3.3.x Kafka建议搭配3.8.x Zookeeper资源占用bitnami镜像比confluent官方镜像更轻量3. 单节点快速部署方案3.1 docker-compose编排文件创建docker-compose.yml文件version: 3.8 services: zookeeper: image: bitnami/zookeeper:3.8.0 container_name: zookeeper ports: - 2181:2181 environment: - ALLOW_ANONYMOUS_LOGINyes volumes: - zookeeper_data:/bitnami networks: - kafka-net kafka: image: bitnami/kafka:3.3.1 container_name: kafka ports: - 9092:9092 environment: - KAFKA_CFG_ZOOKEEPER_CONNECTzookeeper:2181 - ALLOW_PLAINTEXT_LISTENERyes - KAFKA_CFG_ADVERTISED_LISTENERSPLAINTEXT://localhost:9092 volumes: - kafka_data:/bitnami depends_on: - zookeeper networks: - kafka-net kafdrop: image: obsidiandynamics/kafdrop:4.0.0 container_name: kafdrop ports: - 9000:9000 environment: - KAFKA_BROKERCONNECTkafka:9092 - JVM_OPTS-Xms32M -Xmx64M depends_on: - kafka networks: - kafka-net volumes: zookeeper_data: driver: local kafka_data: driver: local networks: kafka-net: driver: bridge3.2 关键参数解析网络配置使用自定义bridge网络(kafka-net)实现容器间通信对外暴露端口9092Kafka broker端口9000Kafdrop管理界面数据持久化通过named volume实现数据持久化生产环境建议改为bind mount指定具体路径环境变量KAFKA_CFG_ADVERTISED_LISTENERS客户端连接地址ALLOW_PLAINTEXT_LISTENER允许明文传输仅限测试启动服务docker-compose up -d访问Kafdrop管理界面 http://localhost:90004. 生产级集群部署方案4.1 多节点集群配置修改后的docker-compose.ymlversion: 3.8 services: zookeeper: image: bitnami/zookeeper:3.8.0 deploy: replicas: 3 environment: - ZOO_SERVER_ID1 - ZOO_SERVERS0.0.0.0:2888:3888;zookeeper2:2888:3888;zookeeper3:2888:3888 - ALLOW_ANONYMOUS_LOGINyes volumes: - zk_data1:/bitnami networks: - kafka-net zookeeper2: image: bitnami/zookeeper:3.8.0 environment: - ZOO_SERVER_ID2 - ZOO_SERVERSzookeeper:2888:3888;0.0.0.0:2888:3888;zookeeper3:2888:3888 - ALLOW_ANONYMOUS_LOGINyes volumes: - zk_data2:/bitnami networks: - kafka-net zookeeper3: image: bitnami/zookeeper:3.8.0 environment: - ZOO_SERVER_ID3 - ZOO_SERVERSzookeeper:2888:3888;zookeeper2:2888:3888;0.0.0.0:2888:3888 - ALLOW_ANONYMOUS_LOGINyes volumes: - zk_data3:/bitnami networks: - kafka-net kafka1: image: bitnami/kafka:3.3.1 environment: - KAFKA_CFG_ZOOKEEPER_CONNECTzookeeper:2181,zookeeper2:2181,zookeeper3:2181 - KAFKA_CFG_BROKER_ID1 - KAFKA_CFG_LISTENER_SECURITY_PROTOCOL_MAPINTERNAL:PLAINTEXT,EXTERNAL:PLAINTEXT - KAFKA_CFG_LISTENERSINTERNAL://:29092,EXTERNAL://:9092 - KAFKA_CFG_ADVERTISED_LISTENERSINTERNAL://kafka1:29092,EXTERNAL://${HOST_IP}:9092 - KAFKA_CFG_INTER_BROKER_LISTENER_NAMEINTERNAL volumes: - kafka_data1:/bitnami depends_on: - zookeeper - zookeeper2 - zookeeper3 networks: - kafka-net # kafka2/kafka3配置类似...4.2 关键优化参数Zookeeper集群奇数节点数量3/5/7每节点需唯一SERVER_ID2888端口用于follower连接leader3888端口用于选举通信Kafka配置environment: - KAFKA_CFG_NUM_PARTITIONS3 # 默认分区数 - KAFKA_CFG_DEFAULT_REPLICATION_FACTOR2 # 默认副本数 - KAFKA_CFG_LOG_RETENTION_HOURS168 # 日志保留7天 - KAFKA_CFG_AUTO_CREATE_TOPICS_ENABLEfalse # 禁用自动创建topic资源限制deploy: resources: limits: cpus: 2 memory: 2G reservations: memory: 1G5. 运维监控与故障排查5.1 健康检查配置为每个服务添加健康检查healthcheck: test: [CMD-SHELL, kafka-topics.sh --bootstrap-server localhost:9092 --list] interval: 30s timeout: 10s retries: 35.2 常见问题处理启动超时问题# 查看容器日志 docker logs -f kafka1 # 常见错误Zookeeper连接失败 # 解决方案增加depends_on条件检查 healthcheck: test: [CMD-SHELL, zkServer.sh status]磁盘空间不足# 修改日志保留策略 environment: - KAFKA_CFG_LOG_RETENTION_BYTES1073741824 # 1GB - KAFKA_CFG_LOG_SEGMENT_BYTES268435456 # 256MB/段性能调优参数environment: - KAFKA_CFG_NUM_IO_THREADS8 - KAFKA_CFG_NUM_NETWORK_THREADS3 - KAFKA_CFG_NUM_RECOVERY_THREADS_PER_DATA_DIR15.3 监控方案Prometheus监控kafka: environment: - KAFKA_CFG_METRICS_ENABLEDtrue - KAFKA_CFG_METRICS_REPORTERSio.confluent.metrics.reporter.ConfluentMetricsReporter日志收集# 查看实时日志 docker-compose logs -f kafka # 生产环境建议配置ELK logging: driver: json-file options: max-size: 10m max-file: 36. 安全加固方案6.1 认证配置SASL/SCRAM认证environment: - KAFKA_CFG_SASL_ENABLED_MECHANISMSSCRAM-SHA-256 - KAFKA_CFG_LISTENER_SECURITY_PROTOCOL_MAPINTERNAL:SASL_PLAINTEXT - KAFKA_CLIENT_USERSadmin,user - KAFKA_CLIENT_PASSWORDSpassword123,user123SSL加密# 生成证书 openssl req -new -x509 -keyout kafka.key -out kafka.crt \ -days 365 -nodes -subj /CNkafka # 配置docker-compose volumes: - ./ssl:/opt/kafka/secrets environment: - KAFKA_CFG_SSL_KEYSTORE_LOCATION/opt/kafka/secrets/kafka.keystore.jks - KAFKA_CFG_SSL_TRUSTSTORE_LOCATION/opt/kafka/secrets/kafka.truststore.jks6.2 网络隔离自定义网络配置networks: kafka-net: driver: bridge ipam: config: - subnet: 172.28.0.0/16防火墙规则# 只允许特定IP访问 iptables -A DOCKER -p tcp --dport 9092 -s 192.168.1.0/24 -j ACCEPT iptables -A DOCKER -p tcp --dport 9092 -j DROP7. 性能压测与优化7.1 基准测试使用kafka-producer-perf-test工具docker exec -it kafka1 bash # 生产者测试 kafka-producer-perf-test \ --topic benchmark \ --num-records 1000000 \ --record-size 1000 \ --throughput -1 \ --producer-props \ bootstrap.serverskafka1:9092 \ acksall \ batch.size16384 # 消费者测试 kafka-consumer-perf-test \ --topic benchmark \ --messages 1000000 \ --bootstrap-server kafka1:90927.2 调优参数对照表参数名默认值推荐值说明num.io.threads816磁盘IO线程数num.network.threads38网络线程数log.flush.interval.messages100005000刷盘消息间隔socket.send.buffer.bytes102400409600发送缓冲区大小log.retention.check.interval.ms30000060000日志清理检查频率7.3 资源监控指标关键指标Under Replicated PartitionsRequest Queue SizeNetwork Processor Avg Idle Percent监控命令# 查看topic详情 docker exec kafka1 kafka-topics --describe \ --bootstrap-server kafka1:9092 # 查看消费者组 docker exec kafka1 kafka-consumer-groups --list \ --bootstrap-server kafka1:90928. 高级功能扩展8.1 Schema Registry集成schema-registry: image: confluentinc/cp-schema-registry:7.3.0 ports: - 8081:8081 environment: - SCHEMA_REGISTRY_HOST_NAMEschema-registry - SCHEMA_REGISTRY_KAFKASTORE_BOOTSTRAP_SERVERSkafka1:9092,kafka2:9092 depends_on: - kafka1 - kafka28.2 Kafka Connect配置kafka-connect: image: confluentinc/cp-kafka-connect:7.3.0 ports: - 8083:8083 environment: - CONNECT_BOOTSTRAP_SERVERSkafka1:9092,kafka2:9092 - CONNECT_GROUP_IDconnect-cluster - CONNECT_CONFIG_STORAGE_TOPICconnect-configs - CONNECT_OFFSET_STORAGE_TOPICconnect-offsets volumes: - ./connectors:/etc/kafka-connect/plugins8.3 多租户隔离方案网络隔离networks: tenant1-net: driver: bridge tenant2-net: driver: bridge资源限制deploy: resources: limits: cpus: 1 memory: 1GACL配置docker exec kafka1 kafka-acls --add \ --allow-principal User:tenant1 \ --operation Read --topic tenant1-* \ --bootstrap-server kafka1:90929. 实际案例订单处理系统9.1 拓扑结构设计订单服务 → (orders topic) → Kafka → → 支付服务(消费组1) → 库存服务(消费组2) → 分析服务(消费组3)9.2 关键配置environment: - KAFKA_CFG_NUM_PARTITIONS6 # 按业务量预估 - KAFKA_CFG_DEFAULT_REPLICATION_FACTOR3 - KAFKA_CFG_MIN_INSYNC_REPLICAS2 - KAFKA_CFG_MESSAGE_MAX_BYTES10485760 # 10MB大消息支持9.3 消费者重试策略// Spring Kafka配置示例 Bean public ConcurrentKafkaListenerContainerFactoryString, String kafkaListenerContainerFactory() { ConcurrentKafkaListenerContainerFactoryString, String factory new ConcurrentKafkaListenerContainerFactory(); factory.setConsumerFactory(consumerFactory()); // 重试策略 factory.setRetryTemplate(retryTemplate()); // 死信队列配置 factory.setRecoveryCallback(context - { Message? message (Message?) context.getAttribute(record); // 发送到死信队列 kafkaTemplate.send(orders.DLT, message.getPayload()); return null; }); return factory; }10. 版本升级与迁移10.1 滚动升级步骤逐个停止Kafka broker更新镜像版本重启并验证重复直到所有节点升级# 检查版本兼容性 docker exec kafka1 kafka-broker-api-versions \ --bootstrap-server kafka1:909210.2 数据迁移方案MirrorMaker2工具docker run confluentinc/cp-kafka:7.3.0 \ /usr/bin/connect-mirror-maker \ /etc/kafka/connect-mirror-maker.properties迁移检查清单验证topic配置一致性检查ACL权限监控消费者偏移量11. 灾备与高可用11.1 跨机房部署kafka: environment: - KAFKA_CFG_ADVERTISED_LISTENERSINTERNAL://kafka1:29092,EXTERNAL_DC1://dc1.example.com:9092,EXTERNAL_DC2://dc2.example.com:909211.2 备份恢复方案元数据备份# 导出topic配置 docker exec zookeeper1 zkCli.sh ls /config/topics数据备份# 使用kafka-dump-log工具 docker exec kafka1 kafka-dump-log \ --files /bitnami/kafka/data/test-0/00000000000000000000.log12. 最佳实践总结分区设计原则每个分区独立顺序保证分区数最大消费者数避免超过10,000分区/broker生产者配置acksall retriesMAX_INT max.in.flight.requests.per.connection1 enable.idempotencetrue消费者配置auto.offset.resetlatest enable.auto.commitfalse fetch.max.bytes52428800 max.poll.records500硬件建议优先考虑磁盘I/O性能建议SSD存储内存配置每百万消息/s约2GB在最后的生产实践中我发现合理设置log.retention.bytes比单纯依赖时间保留更可靠。曾经因为节假日流量激增导致磁盘爆满后来改为大小和时间双重限制才彻底解决问题。另外建议至少每季度执行一次broker滚动重启可以预防很多隐性问题。
