Docker 安装 Kafka 并解决 ZooKeeper 连接拒绝问题

2023-11-11 12:57:39

Docker 中 Kafka 与 ZooKeeper 的连接难题：疑难解答

在 Docker 的容器化世界中，配置 Kafka 和 ZooKeeper 组件以协同工作至关重要。然而，ZooKeeper 连接拒绝的错误可能会让您头疼。在这篇全面的指南中，我们将深入探讨引起此问题的常见原因，并提供逐步解决方案，让您的集群恢复正常运行。

潜在原因及其解决方法

1. Kafka 启动参数不正确

确保 Kafka 启动参数 KAFKA_ZOOKEEPER_CONNECT 设置为 ZooKeeper 容器的 IP 地址和端口。这是 Kafka 连接到 ZooKeeper 的关键配置。

2. 缺少 log4j.properties 配置文件

在 ZooKeeper 容器的 /conf 目录中，必须存在 log4j.properties 配置文件。此文件定义了 ZooKeeper 的日志记录设置，对于其正常运行至关重要。

3. ZooKeeper 服务器连接问题

检查 ZooKeeper 服务器是否正在 localhost:2181 端口上监听。使用 nc 命令连接到该地址，以确保服务器可以通过网络访问。如果无法连接，请检查防火墙设置或网络配置。

附加故障排除步骤

使用 docker ps 命令列出正在运行的容器，并确认 ZooKeeper 容器正在运行。
进入 ZooKeeper 容器的 Bash shell，使用 docker exec -it <container-id> bash 命令，以直接检查其文件和配置。
查看 ZooKeeper 容器的日志，使用 docker logs <container-id> 命令，以识别任何潜在错误或警告。

解决 ZooKeeper 日志记录问题

如果 log4j.properties 文件不存在，请在宿主机上创建此文件：

log4j.rootLogger=INFO, CONSOLE
log4j.appender.CONSOLE=org.apache.log4j.ConsoleAppender
log4j.appender.CONSOLE.layout=org.apache.log4j.PatternLayout
log4j.appender.CONSOLE.layout.ConversionPattern=%d{yyyy-MM-dd HH:mm:ss} %-5p %c{1}:%L - %m%n

将其复制到 ZooKeeper 容器中的 /conf 目录，以配置其日志记录设置。