无法连接flink到kafka

Question

出现以下错误

Caused by: java.lang.NoClassDefFoundError: org/apache/kafka/clients/admin/AdminClient

将 flink 连接到 kafka 时

我正在使用 flink 1.17 并使用

额外的罐子。如果我遗漏了什么，请帮忙。

尝试了不同版本的 Jars，但似乎没有任何效果。我也使用 dataproc 集群来实现同样的目的。

Answer 1

您是否尝试添加 flink-connector-kafka 依赖项？

<dependency>
    <groupId>org.apache.flink</groupId>
    <artifactId>flink-connector-kafka</artifactId>
    <version>1.17.2</version>
</dependency>