問題
當你試圖讀取或寫入數據到Kafka流時,你得到一個錯誤消息。
kafkashaded.org.apache.kafka.common.KafkaException: Failed to construct kafka consumer原因:kafkashaded.org.apache.kafka.common.config.ConfigException:在bootstrap.servers中沒有給出可解析的引導url
如果您正在運行筆記本,則錯誤消息將出現在筆記本單元格中。
如果您正在運行一個JAR作業,錯誤消息將出現在集群驅動程序和工作日誌中(AWS|Azure|GCP).
導致
對象傳遞無效的主機名或IP地址時,會發生此錯誤消息kafka.bootstrap.servers配置在readStream.
這意味著Kafka引導服務器沒有在給定的主機名或IP地址上運行。
解決方案
聯係您的Kafka管理員,以確定環境中Kafka引導服務器的正確主機名或IP地址。
當你在Kafka和Apache Spark結構化流應用程序之間建立連接時,確保你使用了正確的主機名或IP地址。