使用 KafkaUtils.createDirectStream 时出现的问题记录

it2023-08-16  76

问题: 程序从Kafka读数据的程序运行期间报了如下异常:

org.apache.spark.SparkException: Couldn’t find leader offsets for Set

解决方法: 代码中的 zookeeper 相关配置改成主机名,直接用 ip:port 就会报错

192.168.111.200:9092,192.168.111.201:9092,192.168.111.201:9092

修改为:

master:9092,slave1:9092,slave1:9092
最新回复(0)