原因是該kafka集群沒有設置自動創建 topic，所以spark無法創建該 topic，因此也無法找到該 topic 的metadata
所以解決該問題的方法就是：手動創建該 topic
免責聲明！
本站轉載的文章為個人學習借鑒使用，本站對版權不負任何法律責任。如果侵犯了您的隱私權益，請聯系本站郵箱yoyou2525@163.com刪除。
猜您在找
kafka錯誤之 Topic xxx not present in metadata after 60000 ms
Topic xxx not present in metadata after 60000 ms
spring boot 整合kafka 報錯 Exception thrown when sending a message with key='null' and payload=JSON to topic proccess_trading_end: TimeoutException: Failed to update metadata after 60000 ms.
filebeat輸出到kafka
flink job on yarn Timeout expired while fetching topic metadata
java日志輸出到kafka
kafka producer發送消息 Failed to update metadata after問題
【異常】Spark提交到yarn報錯:java.util.concurrent.TimeoutException: Futures timed out after [100000 milliseconds]
Kafka：ZK+Kafka+Spark Streaming集群環境搭建（二十六）Structured Streaming：WARN clients.NetworkClient: Error while fetching metadata with correlation id 1 : {my-topic=LEADER_NOT_AVAILABLE}
spark數據怎樣輸出到Sql Server