apache-airflow-providers-apache-kafka
更新日志¶
1.7.0¶
注意
正如Apache Airflow 提供程序支持策略中所述，此提供程序的版本仅适用于 Airflow 2.9+。
Bug 修复¶
修复 'ConsumeFromTopicOperator' 即使 凭据错误 也不会 失败 （#44307）
其他¶
将 提供程序中 的 最低 Airflow 版本 提升到 Airflow 2.9.0 （#44956）更新 多个 提供程序 文档中 的 DAG 示例 链接 （#44034）
1.6.0¶
注意
正如Apache Airflow 提供程序支持策略中所述，此提供程序的版本仅适用于 Airflow 2.8+。
其他¶
将 提供程序中 的 最低 Airflow 版本 提升到 Airflow 2.8.0 （#41396）
1.5.0¶
功能¶
向 'KafkaAdminClientHook' 添加 'delete_topic' （#40142）
Bug 修复¶
KafkaBaseHook 中的 默认 客户端 （#40284）
其他¶
使用 最低直接依赖项 解析 实现 每个提供程序 的 测试 （#39946）
1.4.1¶
Bug 修复¶
组 id 是 confluent_kafka 2.4.0+ 的 强制性 配置 选项 （#39559）
其他¶
更快 的 'airflow_version' 导入 （#39552）简化 'airflow_version' 导入 （#39497）
1.4.0¶
注意
正如Apache Airflow 提供程序支持策略中所述，此提供程序的版本仅适用于 Airflow 2.7+。
其他¶
将 提供程序中 的 最低 Airflow 版本 提升到 Airflow 2.7.0 （#39240）
1.3.1¶
Bug 修复¶
在 AwaitMessageTrigger 中 向 consumer.commit 提供 已消费的 消息 （#36272）在 子类中 遵循 BaseHook 连接 字段 方法 签名 （#36086）
1.3.0¶
注意
正如Apache Airflow 提供程序支持策略中所述，此提供程序的版本仅适用于 Airflow 2.6+。
其他¶
将 提供程序中 的 最低 Airflow 版本 提升到 Airflow 2.6.0 （#36017）
1.2.0¶
注意
正如Apache Airflow 提供程序支持策略中所述，此提供程序的版本仅适用于 Airflow 2.5+。
Bug 修复¶
修复 错别字 （重复单词 和 it's/its） （#33623）修复 Kafka 提供程序 的最大 消息 限制 错误 （#32926） （#33321）
其他¶
提升 提供程序 的 最低 airflow 版本 （#34728）在 提供程序中 使用 'airflow.exceptions.AirflowException' （#34511）
1.1.0¶
注意
正如Apache Airflow 提供程序支持策略中所述，此提供程序的版本仅适用于 Airflow 2.4+。
其他¶
提升 提供程序中 的 最低 Airflow 版本 （#30917）
1.0.0¶
提供程序的初始版本。