Caused by: org.apache.flink.table.api.ValidationException: Unsupported options found for 'kafka'. Unsupported options: password.encrypt.enabled Supported options:

这个错误是由于在 Flink Table API 中使用了不支持的 Kafka 连接器选项。具体来说，使用了名为 `password.encrypt.enabled` 的选项，该选项在 Flink 中不被支持。

正确的 Kafka 连接器选项可以通过参考 Flink 文档中的 Kafka 连接器部分来获取。您可以检查您的代码并将不支持的选项替换为支持的选项，以解决这个问题。

相关问题

Caused by: java.lang.ClassNotFoundException: org.apache.flink.api.common.functions.FilterFunction

Caused by: java.lang.ClassNotFoundException: org.apache.flink.api.common.functions.FilterFunction 是一个Java异常，表示在运行时找不到指定的类。在这个特定的异常中，它指的是无法找到名为org.apache.flink.api.common.functions.FilterFunction的类。

这个异常通常发生在使用Apache Flink框架时，当尝试使用FilterFunction类时，但是该类在classpath中不存在或无法加载时会抛出此异常。

FilterFunction是Apache Flink中的一个接口，用于定义过滤操作的函数。如果你想在Flink应用程序中使用FilterFunction，你需要确保以下几点：
1. 你的项目依赖中包含了Apache Flink的相关库。
2. 你正确地导入了org.apache.flink.api.common.functions.FilterFunction类。
3. 你的项目构建过程中正确地将相关依赖项添加到classpath中。

如果你已经满足了上述条件，但仍然遇到ClassNotFoundException异常，可能是由于以下原因之一：
1. 你的项目依赖配置有误，可能缺少了Apache Flink相关的库。
2. 你的项目构建过程中没有正确地将依赖项添加到classpath中。
3. 你的项目运行环境中没有正确地配置Apache Flink。

请检查以上条件，并确保你的项目正确地配置了Apache Flink相关的依赖项和运行环境。

Caused by: java.lang.ClassNotFoundException: org.apache.kafka.common.serialization.ExtendedDeserializer

根据提供的引用内容，报错信息显示了一个`java.lang.ClassNotFoundException`异常，异常信息中指出了缺少`org.apache.commons.logging.Log`类。这个异常通常发生在Java应用程序中，当应用程序无法找到所需的类时会抛出该异常。

对于你提到的`Caused by: java.lang.ClassNotFoundException: org.apache.kafka.common.serialization.ExtendedDeserializer`异常，它表示在你的应用程序中无法找到`org.apache.kafka.common.serialization.ExtendedDeserializer`类。这可能是由于缺少相关的依赖库或配置问题导致的。

解决这个问题的方法是确保你的应用程序的类路径中包含了所需的类。你可以尝试以下几种方法来解决这个问题：

1. 确保你的项目中包含了`org.apache.commons.logging.Log`类的依赖库。你可以在项目的构建文件（如`pom.xml`或`build.gradle`）中添加相关的依赖项，以确保该类可用。

2. 检查你的应用程序的配置文件，确保正确配置了相关的类路径。你可以查看应用程序的启动脚本或配置文件，例如`catalina.sh`或`web.xml`，以确保正确设置了类路径。

3. 如果你使用的是Java开发工具（如Eclipse或IntelliJ IDEA），请确保你的项目设置中包含了所需的类。你可以检查项目的构建路径或依赖项设置，以确保相关的类被正确引入。

请注意，具体的解决方法可能因你的应用程序和环境而异。如果以上方法都无法解决问题，你可能需要进一步调查并查找其他可能的原因。