启动 kafka 集群, 出现这个问题 WARN Connection to node 2 could not be established. Broker may not be available. ( vi config/server.properties 修改 ...
最近调试Spark Streaming Kafka,遇到一个连接错误,任务日志如下。 报错之前,ConsumerConfig 被打印出来,其中bootstrap.servers显示我们指定的brokers列表。 根据kafkatool通过ZK可以成功连接的现象,查看 etc hosts,发现brokers的地址是 . . .x 采用Java测试代码验证,发现 . . .x确实可以工作。结合代码分析 ...
2019-06-23 16:23 0 4360 推荐指数:
启动 kafka 集群, 出现这个问题 WARN Connection to node 2 could not be established. Broker may not be available. ( vi config/server.properties 修改 ...
报错背景: 启动kafka消费者之后出现这种报错,持续打印相同信息。 报错现象: 报错原因: 不明。 报错解决: ...
https://blog.csdn.net/Mr_Hou2016/article/details/79484032 ...
请检查Kafka的config/server.properties 看看是否有填写 这里的kafka-host需要在/etc/hosts进行映射,服务端映射到本地或内网ip,客户端映射到服务端ip 问题解决。 ...
本人小白一个,网上查资料,有很多解决方案,有关闭防火墙的,有修改配置文件的,有添加host的,试了之后发现还是解决不了,最后发现是命令用错了 过程如下: cd /opt/kafka/bin #进入kafka安装目录下的bin ./kafka-topics.sh --describe ...
命令:./kafka-console-producer.sh --broker-list zookeeper:9092 --topic monitor 启动kafka生产者报错: 原因:zookeeper端口号写错了! 总结:就算zookeeper端口写错了也能运行,但是只有再 ...
修改 config 下配置文件 vim server.properties 配置本机ip listeners=PLAINTEXT://192.168.174.128:9092 执行命令时 bin/kafka-console-consumer.sh --bootstrap-server ...
场景:安装完kafka集群后,程序创建topic时报错could not be established. Broker may not be available 问题: 1.kafka开放了9092,9093,9094这三个端口,使用语句 firewall-cmd --zone=public ...