說明

Kafka 有的時候會跨機房接收消息，本地開發機也需要向遠程服務器發一些消息，默認是不支持外連的，所以需要配置一下遠程訪問。

Kafka 服務器 host 修改

查看 hostname，查看內網 IP 並記錄

1
2
3
4
cat /etc/hostname
# vm172-31-110-6.ksc.com #
 
ifconfig

編輯 host 文件

1
2
3
vim /etc/hosts
# 添加在文件底部 #
172.31.110.6 vm172-31-110-6.ksc.com

Kafka 配置文件修改

修改 server.properties 配置文件，具體目錄視情況而定。

1
2
3
4
vim /opt/kafka_2.12-2.2.0/config/server.properties
 
# 修改 listeners #
listeners=PLAINTEXT://vm172-31-110-6.ksc.com:9092

需要留意一下 advertised.listeners 要注釋掉，listeners 才會有效。

修改 zookeeper.connect 配置，如果 Zookeeper 和 Kafka 不在同一台機器，請配置 Zookeeper 地址。

1
zookeeper.connect=vm172-31-110-6.ksc.com:2181

客戶端 host 配置

在客戶端機器修改 host 文件映射到遠程外網 IP，內網的 consumer 機器請配置內網 IP 映射。

1
xxx.xx.xx.xx  vm172-31-110-6.ksc.com

注意：重啟kafka

systemctl restart kafka