原文:Spark Streaming + Kafka 常见错误解析 - Connection to node [x] could not be established. Broker may not be available.

最近调试Spark Streaming Kafka,遇到一个连接错误,任务日志如下。 报错之前,ConsumerConfig 被打印出来,其中bootstrap.servers显示我们指定的brokers列表。 根据kafkatool通过ZK可以成功连接的现象,查看 etc hosts,发现brokers的地址是 . . .x 采用Java测试代码验证,发现 . . .x确实可以工作。结合代码分析 ...

2019-06-23 16:23 0 4360 推荐指数:

查看详情

kafka: could not be established. Broker may not be available

本人小白一个,网上查资料,有很多解决方案,有关闭防火墙的,有修改配置文件的,有添加host的,试了之后发现还是解决不了,最后发现是命令用错了 过程如下: cd /opt/kafka/bin #进入kafka安装目录下的bin ./kafka-topics.sh --describe ...

Thu Dec 16 17:35:00 CST 2021 0 1652
KAFKAcould not be established. Broker may not be available

场景:安装完kafka集群后,程序创建topic时报错could not be established. Broker may not be available 问题: 1.kafka开放了9092,9093,9094这三个端口,使用语句 firewall-cmd --zone=public ...

Thu Apr 14 18:32:00 CST 2022 0 8693
 
粤ICP备18138465号  © 2018-2025 CODEPRJ.COM