Flink 1.15版本报错:2023-06-08 18:18:13,878 main ERROR Unable to invoke factory method in class org.apache.logging.log4j.core.appender.mom.kafka.KafkaAppender for element KAFKA: java.lang.IllegalStateException: No factory method found for class org.apache.logging.log4j.core.appender.mom.kafka.KafkaAppender java.lang.IllegalStateException: No factory method found for class org.apache.logging.log4j.core.appender.mom.kafka.KafkaAppender
时间: 2023-10-03 22:08:14 浏览: 247
flink-table-runtime-blink_2.11-1.10.0-API文档-中文版.zip
这个报错可能是由于 Flink 1.15 版本中的 Log4j2 版本更新导致的。可以尝试升级 Log4j2 的 Kafka Appender,或者降级 Flink 版本到 1.14.x 以下。
如果想要升级 Log4j2 的 Kafka Appender,可以在你的项目中添加以下依赖:
```
<dependency>
<groupId>org.apache.logging.log4j</groupId>
<artifactId>log4j-kafka-appender</artifactId>
<version>2.17.0</version>
</dependency>
```
然后在 Flink 的配置文件中,将 `flink.logging.log4j2.appender.kafka` 属性设置为新的 Appender 类全名,如下:
```
flink.logging.log4j2.appender.kafka=org.apache.logging.log4j.kafka.KafkaAppender
```
如果降级 Flink 版本到 1.14.x 以下,可以解决这个报错。
阅读全文