kafka错误之 Topic xxx not present in metadata after 60000 ms
Topic xxx not present in metadata after 60000 ms 一、背景 二、场景还原 1、jar包引入 2、jar代码 3、运行结果 三、问题解决 四、参考文档 ...
原文：Spark Over Yarn 发现输出到kafka报错: topic not present on metadata after x
原因是该kafka集群没有设置自动创建 topic，所以spark无法创建该 topic，因此也无法找到该 topic 的metadata 所以解决该问题的方法就是：手动创建该 topic ...
2020-12-03 16:32 0 980 推荐指数：
相关推荐
Topic xxx not present in metadata after 60000 ms
not present in metadata after 60000 ms. at org.spr ...
filebeat输出到kafka
1、编辑filebeat的配置文件 # cat filebeat.yml ...
flink job on yarn Timeout expired while fetching topic metadata
flink on yarn 以session模式跑flink任务时，当运行命令时，Task Managers 中logs打印警告日志如下： WARN [Producer clientId=console-producer] Connection to node -1 could ...
java日志输出到kafka
log4j2.xml 如下图，13-17行内配置kafka信息，以及id名字，在35行输出日志，在43行选择日志格式 需要添加依赖 ...
kafka producer发送消息 Failed to update metadata after问题
提示示例： ERROR Error when sending message to topic test with key: null, value: 2 bytes with error: Failed to update metadata after 60000 ms. 解决方案 ...
【异常】Spark提交到yarn报错:java.util.concurrent.TimeoutException: Futures timed out after [100000 milliseconds]
1 详细异常 java.util.concurrent.TimeoutException: Futures timed out after [100000 milliseconds] at scala.concurrent.impl.Promise ...