Topic xxx not present in metadata after 60000 ms 一、背景 二、場景還原 1、jar包引入 2、jar代碼 3、運行結果 三、問題解決 四、參考文檔 ...
原因是該kafka集群沒有設置自動創建 topic,所以spark無法創建該 topic,因此也無法找到該 topic 的metadata 所以解決該問題的方法就是:手動創建該 topic ...
2020-12-03 16:32 0 980 推薦指數:
Topic xxx not present in metadata after 60000 ms 一、背景 二、場景還原 1、jar包引入 2、jar代碼 3、運行結果 三、問題解決 四、參考文檔 ...
not present in metadata after 60000 ms. at org.spr ...
1、編輯filebeat的配置文件 # cat filebeat.yml ...
flink on yarn 以session模式跑flink任務時,當運行命令時,Task Managers 中logs打印警告日志如下: WARN [Producer clientId=console-producer] Connection to node -1 could ...
log4j2.xml 如下圖,13-17行內配置kafka信息,以及id名字,在35行輸出日志,在43行選擇日志格式 需要添加依賴 ...
提示示例: ERROR Error when sending message to topic test with key: null, value: 2 bytes with error: Failed to update metadata after 60000 ms. 解決方案 ...
1 詳細異常 java.util.concurrent.TimeoutException: Futures timed out after [100000 milliseconds] at scala.concurrent.impl.Promise ...