Elonyong 2019-03-10 17:10 采纳率: 0%
浏览 2093

kafka 集群映射端口到外网,外网无法生产消息

有3台kafka

ip分别是内网ip

192.168.2.21 9092

192.168.2.22 9092

192.168.2.23 9092

另有一台同时接通了内网和互联网的机器
(内网ip 192.168.2.13,外网ip 172.50.63.1),

现在用这台机器做了端口映射,用的rinetd

0.0.0.0 9092 192.168.2.21 9092

0.0.0.0 9093 192.168.2.22 9092

0.0.0.0 9094 192.168.2.23 9092

然后在自己开发电脑上用java代码生产消息 topic=ffff

props.put("bootstrap.servers", "172.50.63.1:9092");

会产生如下报错

java.util.concurrent.ExecutionException: org.apache.kafka.common.errors.TimeoutException: Batch containing 1 record(s) expired due to timeout while requesting metadata from brokers for ffff-0
    at org.apache.kafka.clients.producer.internals.FutureRecordMetadata.valueOrError(FutureRecordMetadata.java:65)
    at org.apache.kafka.clients.producer.internals.FutureRecordMetadata.get(FutureRecordMetadata.java:52)
    at org.apache.kafka.clients.producer.internals.FutureRecordMetadata.get(FutureRecordMetadata.java:25)
    at Producer.run(Producer.java:140)
Caused by: org.apache.kafka.common.errors.TimeoutException: Batch containing 1 record(s) expired due to timeout while requesting metadata from brokers for ffff-0

这是我的kafka配置

listeners=PLAINTEXT://0.0.0.0:9092
advertised.listeners=PLAINTEXT://192.168.2.13:9092

现在的疑问是
这个配置应该写什么?才能让外网能够正常生产

advertised.listeners应该写互联网ip 172.50.63.1

还是做映射的那台内网ip 192.168.2.13

  • 写回答

1条回答 默认 最新

  • yflwz 2019-10-23 23:20
    关注

    advertised.listeners应该写互联网ip 172.50.63.1

    评论

报告相同问题?

悬赏问题

  • ¥50 永磁型步进电机PID算法
  • ¥15 sqlite 附加(attach database)加密数据库时,返回26是什么原因呢?
  • ¥88 找成都本地经验丰富懂小程序开发的技术大咖
  • ¥15 如何处理复杂数据表格的除法运算
  • ¥15 如何用stc8h1k08的片子做485数据透传的功能?(关键词-串口)
  • ¥15 有兄弟姐妹会用word插图功能制作类似citespace的图片吗?
  • ¥200 uniapp长期运行卡死问题解决
  • ¥15 latex怎么处理论文引理引用参考文献
  • ¥15 请教:如何用postman调用本地虚拟机区块链接上的合约?
  • ¥15 为什么使用javacv转封装rtsp为rtmp时出现如下问题:[h264 @ 000000004faf7500]no frame?