spark包鏈接kafka集羣報錯org.apache.kafka.common.KafkaException: Failed to construct kafka consumer

1、如果是spark執行的包請到spark下面的jars文件夾裏檢索是否擁有相關的jar包 可以看到我這裏是有的,那就不是jar包的問題 2、確認是不是版本問題,在自己的本地測試裏看一下maven的包 我這邊版本是一致的,所以也不是版本問題,那是什麼原因造成創建消費失敗的呢 3、kafka的鏈接 可以看到kafka是用了集羣的,三個鏈接是配置了hosts的,我們看一下我們運行節點的hosts 但是
相關文章
相關標籤/搜索