SparkStreaming
-
allocatedirect_SparkStreaming消费Kafka消息失败,提示“Couldn't find leader offsets”
问题描述在Spark Streaming中,使用allocateDirect方式消费Kafka消息时出现失败,提示信息为:“Couldn’t find leader offsets”。可能的原因1、Kafka集群状态:Kafka集群可能处于不可用或不稳定状态。2、网络问题:Spark与Kafka之间的网络连接可……