java.util.concurrent.ExecutionException: org.apache.kafka.common.errors.TimeoutException: Topic logTranfer not present in metadata after 60000 ms.

71可以发送,但相同的另一套平台21发送失败。

1、

kafka-topics.sh --list --bootstrap-server node1:9092

确保kafka集群下有这个分区,查看了是有的

2、确认Jmeter配置正确

因为71可以发送,21配置只更改了IP地址,这一部分应该是没有问题

3、添加必要的生产者配置

查了下可能是这里添加,但添加了还是报错

4、检查网络连接,确保Jmeter可以连接到kafka集群

4.1 

telnet 10.71 9092是连接成功的,telnet 10.21 9092连接失败

应该就是这个问题。想起来之前10.21安装的时候加了防火墙设置

systemctl status firewalld查询防火墙状态,果然10.71的防火墙是关着的,而10.21的防火墙开着,且通过firewall-cmd --list-ports查看开放的端口没有9092:

通过命令开启服务器防火墙9092端口:

firewall-cmd --zone=public --add-port=9092/tcp --permanent
firewall-cmd --reload
firewall-cmd --list-ports(查看开放端口)

之后如果需要关闭端口,则执行:

firewall-cmd --zone=public --remove-port=9092/tcp --permanent
firewall-cmd --reload

5、开启端口后再Jmeter执行发送数据,查看结果树显示成功

问题到此解决

Logo

汇聚全球AI编程工具,助力开发者即刻编程。

更多推荐