Couldn't find leader offsets for Set([smt,0], [smt,1], [smt,2])

Couldn‘t find leader offsets for Set ([luwc_test,0],[luwc_test,1]) 异常问题。解决方案：要在kafka集群的hosts要配到spark的Driver的hosts里面去，用zk管kafka的话，是可以获取到Partition信息的， 但是解析地址会失败，把hosts配成一致就可以了，直接用domain是不行的。
创作挑战赛新人创作奖励来咯，坚持创作打卡瓜分现金大奖

总结

以上是生活随笔为你收集整理的Couldn't find leader offsets for Set([smt,0], [smt,1], [smt,2])的全部内容，希望文章能够帮你解决所遇到的问题。

如果觉得生活随笔网站内容还不错，欢迎将生活随笔推荐给好友。