南宁免费网站建站模板百度关键词查询

一、是否需要配置 Zookeeper？

Kafka 集群的 Zookeeper 依赖性与版本及运行模式相关：

Kafka 版本	是否需要 Zookeeper	说明
0.11.x 及更早版本	✅ 必须配置	Kafka 完全依赖 Zookeeper 管理元数据
2.8 及以下版本	✅ 必须配置	Kafka 依赖外置或内置的 Zookeeper 服务
3.0 及以上版本	❌ 无需配置（KRaft 模式）	若集群启用 KRaft（无 Zookeeper），则直接通过 Broker 地址连接
3.0 及以上版本	✅ 需要配置（非 KRaft 模式）	若仍使用传统 Zookeeper 模式，则需按旧版本方式配置

二、配置步骤详解（以 Kafka 0.11.0.0 为例）

1. 获取 Zookeeper 连接信息

从 Kafka 的配置文件 server.properties 中获取 Zookeeper 地址：

• 查找配置项：

  zookeeper.connect=kafka-node1:2181,kafka-node2:2181,kafka-node3:2181

• 确保地址和端口与集群实际配置一致。

2. 配置 Zookeeper（必需）

1. 打开 Offset Explorer，进入 Properties 选项卡。
2. 填写以下信息：
   • Cluster Name：自定义集群名称（如 Kafka-Cluster-0.11）。
   • Zookeeper Host： `kafka-hjgh-01.hjgh.svc.cluster.local。
   • Zookeeper Port： 2181 格式：host
   • Kafka Cluster Version：填写 0.11。
     

3. 配置 Kafka Broker（可选但推荐）

虽然 Kafka 0.11 主要通过 Zookeeper 连接，但配置 Broker 可增强兼容性：

1. 进入 Advanced 选项卡。
2. 填写以下信息：
   • Bootstrap Servers：
     格式：host1:port1,host2:port2,host3:port3
     示例：
     kafka-node:30001,kafka-node:30002,kafka-node:30003
   • SASL Mechanism（可选）：
     若启用 SASL 认证，填写机制类型（如 PLAIN），否则留空。

4. 配置security（可选但推荐）

kafka配置文件 server.properties搜索security.inter.broker.protocol
如果
security.inter.broker.protocol=SASL_PLAINTEXT
则选择SASL_PLAINTEXT模式，并且需要在JAAS config当中配置用户名密码，JAAS config内容可以从配置文件kafka_client_jaas.conf当中获取。
否则security默认Plaintext

5. 测试连接

1. 点击 Test 按钮。
2. 检查是否返回 Success 状态，确认集群可访问。
3. 若失败，检查：
   • Zookeeper/Broker 地址和端口是否正确。
   • 网络连通性（使用 telnet 测试）。
   • 防火墙是否开放端口。

---

三、注意事项

1. 版本兼容性：

   • Kafka 0.11 必须通过 Zookeeper 连接，Offset Explorer 需支持旧版本协议。
   • 若使用新版 Offset Explorer，需确认其兼容 Kafka 0.11。

2. 网络配置：

   • 确保 Offset Explorer 所在机器能访问所有 Zookeeper 和 Broker 节点。
   • 检查防火墙规则是否允许流量通过相关端口。
   • 链接成功后，可能broken使用的是内部域名，需要在本地hosts文件当中做一层映射，不然无法连接到broken

3. 安全配置：

   • 若集群启用 ACL 或 SSL，需在 Offset Explorer 中配置对应证书和密钥。