Kafka在Ubuntu上的网络配置要点

1. 配置静态IP地址

Kafka需要稳定的网络标识，因此Ubuntu服务器应使用静态IP而非DHCP。通过Netplan工具（Ubuntu 20及以上版本默认）修改网络配置：编辑/etc/netplan/01-netcfg.yaml文件，将dhcp4: yes改为no，并添加静态IP、网关和DNS服务器信息。示例如下：

network:
  version: 2
  renderer: networkd
  ethernets:
    eth0:
      dhcp4: no
      addresses: ["192.168.1.100/24"]  # 替换为你的静态IP和子网掩码
      gateway4: "192.168.1.1"         # 替换为你的网关IP
      nameservers:
        addresses: ["8.8.8.8", "8.8.4.4"]  # 替换为你的DNS服务器

应用配置：sudo netplan apply。

2. 配置Kafka核心网络参数

编辑Kafka安装目录下的config/server.properties文件，关键参数设置如下：

listeners：指定Kafka监听的地址和端口，若需允许所有网络接口访问，可设置为PLAINTEXT://0.0.0.0:9092；若仅限本地访问，用PLAINTEXT://localhost:9092。
advertised.listeners：客户端连接Kafka时使用的地址，需设置为Kafka broker对外可访问的IP或域名（如集群内其他节点或客户端所在网络的IP）。示例如下：
- 单机模式：PLAINTEXT://192.168.1.100:9092
- 集群模式：需区分内部和外部监听，例如：
```
listeners=INTERNAL://192.168.1.100:9092,EXTERNAL://public-ip:9092
advertised.listeners=INTERNAL://192.168.1.100:9092,EXTERNAL://public-ip:9092
listener.security.protocol.map=INTERNAL:PLAINTEXT,EXTERNAL:PLAINTEXT
```
zookeeper.connect：Zookeeper集群地址，单机Zookeeper用localhost:2181，集群用host1:2181,host2:2181,host3:2181。

3. 防火墙与安全组设置

确保Ubuntu防火墙（如UFW）或云服务商安全组允许Kafka端口（默认9092）和Zookeeper端口（默认2181）的入站流量：

UFW配置：

sudo ufw allow 9092/tcp  # Kafka端口
sudo ufw allow 2181/tcp  # Zookeeper端口
sudo ufw reload

iptables配置（可选）：

sudo iptables -A INPUT -p tcp --dport 9092 -j ACCEPT
sudo iptables -A INPUT -p tcp --dport 2181 -j ACCEPT
sudo service iptables save

4. 高级网络优化

内外网分离：若Kafka需对外提供服务，配置listeners和advertised.listeners区分内部（集群节点间）和外部（客户端）访问，确保外部客户端通过公网IP连接，内部节点通过内网IP通信。
启用压缩：在server.properties中设置compression.type=gzip（或其他算法如snappy、lz4），减少网络传输的数据量，提升传输效率。
调整TCP参数：通过sysctl命令优化TCP缓冲区大小（如net.core.rmem_max=16777216、net.core.wmem_max=16777216），或修改Kafka的socket.send.buffer.bytes（发送缓冲区）和socket.receive.buffer.bytes（接收缓冲区）参数，提升网络吞吐量。

5. 验证网络配置

测试Kafka服务：创建Topic并启动生产者和消费者，验证消息收发是否正常：

# 创建Topic
/opt/kafka/bin/kafka-topics.sh --create --bootstrap-server localhost:9092 --replication-factor 1 --partitions 1 --topic test
# 启动生产者
/opt/kafka/bin/kafka-console-producer.sh --broker-list localhost:9092 --topic test
# 启动消费者（新终端）
/opt/kafka/bin/kafka-console-consumer.sh --bootstrap-server localhost:9092 --topic test --from-beginning

检查端口连通性：使用telnet或nc命令测试客户端与Kafka broker的端口连通性：
```
telnet your.kafka.broker.ip 9092
# 或
nc -zv your.kafka.broker.ip 9092
```