功能概述

用户可通过内网地址与公网地址访问 Kafka 集群。Kafka 集群的连接格式为 host_ip1:port,host_ip2:port,host_ip3:port。

  • host_ip 为 Kafka 节点的 IP 地址，可以为节点内网 IP，也可以为 Kafka 节点绑定的公网 IP 地址。用户可根据需求进行选择。

  • port 为客户端节点的访问端口。通过内网访问和公网访问都是 9092。

操作步骤

为了达到最高的性能，青云QingCloud建议用户将 Kafka 集群和客户端部署于同一个 VPC 网络内。若在实际使用中，出现 Producer、Consumer 与 Broker 都不在同一个 VPC 网络内，此时可参考以下步骤，进行跨 VPC 使用。

方法一：打通内网

通过边界路由器、IPsec 隧道、GRE 隧道 等方式打通网络。这种方式适合于大规模复杂网络的情况。

方法二：配置 VPN

配置 VPN。这种方法通常用于本地开发测试。

方法三：开启公网访问

为集群开启公网访问。开启公网访问后，任何服务都可以通过公网 IP 连接到 Kafka 集群。适用于有公网访问需求的场景。

方法四：修改集群配置参数

通过集群参数集群参数，将 Kafka 服务对外暴露。这种方式只适用于 单节点 Kafka 集群。Kafka 0.10.2.1 - v1.16 和 Kafka 1.0.0 - v1.1.8 版本支持单节点集群。操作步骤如下。

  1. 在 Broker 所在的路由器上配置端口转发。详情参考如何配置端口转发。

  2. 修改 Kafka 集群的配置参数 advertised.host.name 与 advertised.port 为路由器转发的源地址和源端口。详情参考修改配置参数。

    • 示例说明

      假设路由器的 IP 地址为 207.226.141.61，端口为 9080，转发到 Kafka Broker 节点的 IP 地址为 192.168.0.10，端口为 9092。用户需修改 advertised.host.name 为 207.226.141.61，修改 advertised.port 为 9080。

    • 配置结果

      modify parameter