springboot~連接kafka需要注意的地方
kafka需要zookeeper的支持,我們可以使用docker-compose簡單的部署一個環境,在部署時,kafka需要我們為它配置一個hostname,這個名稱是每個kafka節點(broken)的名稱,也是很容易被忽視的地方,通過kafka客戶端工具可以看到你當前部署kafka時的hostsname,在部署java時,你的主機也需要配置這個host.

部署一個kafka
docker-compose實現
version: '2'
services:
zookeeper:
image: wurstmeister/zookeeper
hostname: zookeeper1
network_mode: bridge
ports:
- "2181:2181"
kafka:
image: wurstmeister/kafka:2.11-0.11.0.3
hostname: kafka1
network_mode: bridge
links:
- zookeeper
ports:
- "9092:9092" #表示宿主機的端口為隨機,這樣方便使用docker-compose scale 進行擴容
environment:
KAFKA_ADVERTISED_LISTENERS: PLAINTEXT://:9092
KAFKA_LISTENERS: PLAINTEXT://:9092
KAFKA_ZOOKEEPER_CONNECT: zookeeper:2181
部署一個應用,使用k8s配置容器hosts
spec:
template:
spec:
hostAliases:
- ip: "192.168.60.146"
hostnames: ["kafka1"]
在java應用中可以直接連接kafka的地址和端口
