allocatedirect
问题描述 在Spark Streaming中，使用allocateDirect 方式消费Kafka消息时出现失败，提示信息为：“Couldn’t find leader offsets”。 可能的原因 1、Kafka集群状态 ：Kafka集群可能处于不可用或不稳定状态。 2、网络问题 ：Spark与Kafka之间的网络连接可能存在问题。 3、版本兼容性 ...
免责声明：本站内容（文字信息+图片素材）来源于互联网公开数据整理或转载，仅用于学习参考，如有侵权问题，请及时联系本站删除，我们将在5个工作日内处理。联系邮箱：303555158#qq.com（把#换成@）
微信便捷交流