用java api当远程生产者,服务器端 advertised.listener 已设置成外网IP,JAR包与版本也匹配,在生产的时候会报这个错误。
telnet可以通
设置成内网ip。
感谢回复,我也试过换成内网IP,阻塞式发送的时候还是会报超时异常
org.apache.kafka.common.errors.TimeoutException: Expiring 1 record(s) for test-0: 30054 ms has passed since batch creation plus linger time
对了,服务器端kafka会报一个这样的异常
WARN [SocketServer brokerId=0] Unexpected error from /222.20.73.243; closing connection (org.apache.kafka.common.network.Selector)org.apache.kafka.common.network.InvalidReceiveException: Invalid receive (size = 1585253642 larger than 104857600)
不好意思,上面是我断开telnet的时候出现的,和java api没有关系
加这个配置:
listeners=PLAINTEXT://10.xx.xx.56:9092
额,加了之后也是一样的情况
这就跟奇怪了,telnet也通,内网和外网都试过了。防火墙也关了试试。
感谢您,问题已经解决了,是服务器的问题,换了一台阿里服务器已经好了
找不到想要的答案?提一个您自己的问题。
0 声望
这家伙太懒,什么都没留下
设置成内网ip。
感谢回复,我也试过换成内网IP,阻塞式发送的时候还是会报超时异常
对了,服务器端kafka会报一个这样的异常
不好意思,上面是我断开telnet的时候出现的,和java api没有关系
加这个配置:
额,加了之后也是一样的情况
这就跟奇怪了,telnet也通,内网和外网都试过了。
防火墙也关了试试。
感谢您,问题已经解决了,是服务器的问题,换了一台阿里服务器已经好了
你的答案