在 Apache Airflow 中设置 Kafka 连接时出错 - “必须提供 config['bootstrap.servers']”

Question

我在尝试在 Apache Airflow 中建立与 Apache Kafka 的连接时遇到错误。我收到的具体错误消息是“必须提供 config['bootstrap.servers']”。尽管提供了 Kafka 服务器详细信息，问题仍然存在。 迄今为止采取的步骤： 使用以下 pip 命令安装 Apache Airflow 的 Kafka 提供程序： pip 安装 apache-airflow-providers-apache-kafka 访问 Airflow UI 并尝试创建连接，但遇到上述错误。 我已验证 Airflow UI 中的配置设置，并确保包含指定 Kafka 代理地址列表的“bootstrap.servers”参数。然而，问题仍然没有解决。 将不胜感激任何解决此问题的见解或建议。预先感谢您的帮助。

Answer 1

请确保您已安装“confluence-kafka”Python 包。安装这个软件包解决了我的问题。

希望这有帮助。