无法为Pulsar上的Kafka正确配置Kafka监听器
Kubernetes环境下Pulsar KOP监听器IP配置方案
集群内部访问(ClusterIP Service)
监听器配置填写0.0.0.0,因为Broker Pod需要监听所有网络接口,才能接收K8s Service转发的流量。示例配置:kafkaListeners=PLAINTEXT://0.0.0.0:9092外部客户端访问(NodePort/LoadBalancer)
不管用NodePort还是LoadBalancer类型的Service,监听器IP依然填0.0.0.0:- NodePort场景:外部客户端通过「节点IP:NodePort」访问
- LoadBalancer场景:外部客户端通过负载均衡器分配的IP访问
核心原因是K8s中Pod IP是动态变化的,固定IP会导致Pod重启或调度后服务失效,让Pod监听所有接口,由Service负责流量路由才是合理方案。
额外配置提示
如果需要让外部客户端识别固定的访问地址,可以在kafkaAdvertisedListeners配置项中设置负载均衡器IP或自定义域名,比如:kafkaAdvertisedListeners=PLAINTEXT://<负载均衡器IP>:9092
内容的提问来源于stack exchange,提问作者user22886506
相关产品推荐
相关产品推荐

