advertised Kafka配置内外网访问

本文介绍了如何在内外网环境下配置Kafka的访问。我们需要在Kafka的配置文件中设置listeners属性，以允许内网和外网的客户端连接。我们需要配置防火墙规则，以允许内网和外网的流量通过。我们需要测试Kafka的访问，以确保配置正确。

配置Kafka内外网访问

内网访问配置

1、修改Kafka配置文件

找到Kafka的配置文件server.properties，通常位于/etc/kafka/目录下，使用文本编辑器打开文件，找到以下配置项并进行修改：

“`

listeners=PLAINTEXT://:9092

advertised.listeners=PLAINTEXT://<内网IP地址>:9092

“`

将<内网IP地址>替换为实际的内网IP地址。

2、重启Kafka服务

保存配置文件后，重启Kafka服务以使更改生效，在Linux系统中，可以使用以下命令重启Kafka：

“`

sudo systemctl restart kafka

“`

外网访问配置

1、修改Kafka配置文件

同样找到Kafka的配置文件server.properties，并修改以下配置项：

“`

listeners=PLAINTEXT://:9092

advertised.listeners=PLAINTEXT://<外网IP地址>:9092

“`

将<外网IP地址>替换为实际的外网IP地址，注意，这里的外网IP地址需要是公网可访问的IP地址。

2、配置防火墙规则

为了允许外部访问Kafka服务，需要在服务器的防火墙上添加相应的规则，以下是在Linux系统中配置防火墙规则的命令：

“`

sudo iptables A INPUT p tcp dport 9092 j ACCEPT

sudo iptablessave | sudo tee /etc/iptables/rules.v4 # 保存防火墙规则到文件

“`

3、重启Kafka服务和防火墙

保存配置文件后，重启Kafka服务以使更改生效，重启防火墙以应用新的规则：

“`

sudo systemctl restart kafka

sudo systemctl restart iptables

“`

测试内外网访问

1、内网访问测试

在内网环境中，使用Kafka客户端工具连接到Kafka服务进行测试，使用kafkaconsoleconsumer命令消费消息：

“`

kafkaconsoleconsumer bootstrapserver <内网IP地址>:9092 topic test_topic frombeginning

“`

2、外网访问测试

在外网环境中，使用Kafka客户端工具连接到Kafka服务进行测试，使用kafkaconsoleconsumer命令消费消息：

“`

kafkaconsoleconsumer bootstrapserver <外网IP地址>:9092 topic test_topic frombeginning

“`

下面是一个关于配置Kafka以支持内外网访问的介绍：

参数名称	描述	内网访问配置示例	外网访问配置示例
listeners	Kafka用于监听客户端连接的协议和地址列表。	listeners=PLAINTEXT://192.168.1.10:9092	listeners=PLAINTEXT://0.0.0.0:9092
advertised.listeners	用来通知外部代理或客户端的Kafka的地址，用于外网访问，若不设置，默认使用listeners配置。	advertised.listeners=PLAINTEXT://192.168.1.10:9092	advertised.listeners=PLAINTEXT://:9092
zookeeper.connect	Kafka连接到ZooKeeper的地址。	zookeeper.connect=192.168.1.20:2181	可能需要保持内网地址，或者使用公网可访问的ZooKeeper集群
inter.broker.listener.name	用于Kafka集群内部broker之间通信的监听器名称。	inter.broker.listener.name=PLAINTEXT	inter.broker.listener.name=PLAINTEXT
broker.id	每个Kafka实例的唯一标识。	broker.id=0	broker.id=0
host.name	Kafka服务器的完全限定域名或IP地址，若设置，将用于广告给外部客户端的地址。	host.name=192.168.1.10	host.name=
advertised.host.name	如果不设置host.name，可以通过这个参数指定外部客户端可见的地址。	未设置	advertised.host.name=
ssl.keystore.location	SSL证书的存储位置，若使用SSL加密通讯。	ssl.keystore.location=/path/to/keystore.jks	ssl.keystore.location=/path/to/keystore.jks
ssl.truststore.location	SSL信任存储的位置，若使用SSL加密通讯。	ssl.truststore.location=/path/to/truststore.jks	ssl.truststore.location=/path/to/truststore.jks

请注意，在实际配置时，您需要将示例中的IP地址和参数值替换成您自己环境中的具体信息，外网访问配置通常涉及安全考虑，所以可能还需要配置SSL加密、Kafka用户认证、网络防火墙规则等安全措施。