返回到文章

采纳

编辑于

内网kafka,映射ip端口到外网。在外网无法使用

kafka

各位大神,请教一个问题。实在不知道怎么整了,是这样的情形,公司内网做的kafka集群是三个结点,具体怎么做的我不知道,我们使用时是在springboot中配置三个地址(brokers:ip:9092,IP:9092,IP:9092。zk-nodes:IP:2181,IP:2181,IP:2181)。

然后现在分别做映射到了外网分别有对应的ip和端口。springboot中kafka却是不能用的。然后我在外网机器上弄了一个kafka,去向公司的kafka发送消息一直报错:

ERROR Error when sending message to topic test999 with key: null, value: 1 bytes with error: (org.apache.kafka.clients.producer.internals.ErrorLoggingCallback)
org.apache.kafka.common.errors.TimeoutException: Expiring 1 record(s) for test999-0: 1504 ms has passed since batch creation plus linger time。

然后我把advertised.listeners=PLAINTEXT://***:9092改成公司某一个结点,报下面的错

WARN Connection to node -1 could not be established. Broker may not be available. (org.apache.kafka.clients.NetworkClient)

不知道怎么改,属于小白级别,忘指点迷津。