nigix转发kafka 连不上

偉QQ廣 发表于: 2019-09-06   最后更新时间: 2019-09-06  

nigix转发kafka 连不上

问题描述

我这边有三台服务器,A,B,C,其中A不能与C联通,只能通过B转发。

现在就是A启动了Kafka,C是spring boot开发的 消费者.但是C通过B的nigix 连不上Kafka,导致C启动报错

报错信息

2019-09-03 14:37:53 [org.springframework.kafka.KafkaListenerEndpointContainer#0-0-C-1] INFO  org.springframework.kafka.listener.KafkaMessageListenerContainer - partitions revoked: []
2019-09-03 14:37:53 [org.springframework.kafka.KafkaListenerEndpointContainer#0-0-C-1] INFO  org.apache.kafka.clients.consumer.internals.AbstractCoordinator - [Consumer clientId=consumer-1, groupId=KAFKA_GROUP_ID_ONE] (Re-)joining group
2019-09-03 14:38:14 [org.springframework.kafka.KafkaListenerEndpointContainer#0-1-C-1] WARN  org.apache.kafka.clients.NetworkClient - [Consumer clientId=consumer-2, groupId=KAFKA_GROUP_ID_ONE] Connection to node 2147483647 could not be established. Broker may not be available.
2019-09-03 14:38:14 [org.springframework.kafka.KafkaListenerEndpointContainer#0-5-C-1] WARN  org.apache.kafka.clients.NetworkClient - [Consumer clientId=consumer-6, groupId=KAFKA_GROUP_ID_ONE] Connection to node 2147483647 could not be established. Broker may not be available.

已经尝试过哪些方法仍然没解决,操作步骤等

尝试修改kafka的配置server.property文件

listeners=PLAINTEXT://:9092
advertised.listeners=PLAINTEXT://your.host.name:9092

用IP,localhost、0.0.0.0、都不行。



您需要解锁本帖隐藏内容请: 点击这里
本帖隐藏的内容




偉QQ廣 发表于: 9天前   最后更新时间: 9天前   游览量:131

上一条: Kafka消费者配置问题
下一条: kafka消息顺序并发处理问题

  • kafka客户端是通过连接到某个kafka集群 节点,察觉其他节点的,所以客户端获取到的就是原kafka真实IP,而不是你转换后的。

    所以,你可以通过路由转发或用域名,客户端host配置好想转发的地址。

    • 假设

      外网Kafka服务器A机器
      IP:192.168.0.58
      内网代理服务器B机器
      IP:192.168.1.82
      内网消费者客户端C机器
      IP:192.168.1.130
      ,其中C是不能访问A的。

      1、外网A机器kafka中server.properties配置
      listeners=PLAINTEXT://192.168.0.58:6379
      advertised.listeners=PLAINTEXT://kf-kafka:6379
      2、外网Kafka服务器A机器的hosts:
      192.168.0.58 kf-kafka
      3、内网消费者客户端C机器的hosts:
      192.168.1.82 kf-kafka

        • 是的,host是这么配,你把A机kafka配置文件改成

          listeners=PLAINTEXT://kj-kafka:6379
          

          advertised.listeners已经弃用了,可以删掉,在试试。