apache-airflow-providers-apache-kafka
变更日志¶
1.8.1¶
杂项¶
移除 多余的 else 块 (#49199)
1.8.0¶
特性¶
创建 用于处理 GCP Apache Kafka 消费者组的 算子 (#47056)
杂项¶
移除 apache-kafka provider 中的 google provider 依赖 (#47563)移除对 confluent-kafka 的 排除 (#47240)暂时限制 confluent-kafka 版本以 排除 2.8.1 (#47204)将旧版 命名空间 包 添加到 airflow.providers. (#47064)
1.7.0¶
注意
此 provider 版本仅适用于 Airflow 2.9+，详情请参阅 Apache Airflow provider 支持策略。
错误修复¶
修复即使 凭证错误 'ConsumeFromTopicOperator' 也不失败的问题 (#44307)
杂项¶
将 provider 中的最低 Airflow 版本提升至 Airflow 2.9.0 (#44956)更新多个 provider 文档中 的 DAG 示例 链接 (#44034)
1.6.1¶
错误修复¶
从 kafka operator 的 template_fields 中 移除 可调用 函数参数 (#42555)
1.6.0¶
注意
此 provider 版本仅适用于 Airflow 2.8+，详情请参阅 Apache Airflow provider 支持策略。
杂项¶
将 provider 中的最低 Airflow 版本提升至 Airflow 2.8.0 (#41396)
1.5.0¶
特性¶
将 'delete_topic' 添加 到 'KafkaAdminClientHook' (#40142)
错误修复¶
KafkaBaseHook 中的默认 客户端 (#40284)
杂项¶
实现带最低 直接依赖 解析的 逐个 provider 测试 (#39946)
1.4.1¶
错误修复¶
对于 confluent_kafka 2.4.0+， Group id 是强制 配置选项 (#39559)
杂项¶
加快 'airflow_version' 导入速度 (#39552)简化 'airflow_version' 导入 (#39497)
1.4.0¶
注意
此 provider 版本仅适用于 Airflow 2.7+，详情请参阅 Apache Airflow provider 支持策略。
杂项¶
将 provider 中的最低 Airflow 版本提升至 Airflow 2.7.0 (#39240)
1.3.1¶
错误修复¶
在 AwaitMessageTrigger 中向 consumer.commit 提供 已消费的 消息 (#36272)在子类中 遵循 BaseHook connection fields 方法 签名 (#36086)
1.3.0¶
注意
此 provider 版本仅适用于 Airflow 2.6+，详情请参阅 Apache Airflow provider 支持策略。
杂项¶
将 provider 中的最低 Airflow 版本提升至 Airflow 2.6.0 (#36017)
1.2.0¶
注意
此 provider 版本仅适用于 Airflow 2.5+，详情请参阅 Apache Airflow provider 支持策略。
错误修复¶
修复拼写错误 (重复词和 it's/its) (#33623)修复 Kafka provider 的 最大 消息限制 错误 (#32926) (#33321)
杂项¶
提升 provider 的最低 airflow 版本 (#34728)在 provider 中使用 'airflow.exceptions.AirflowException' (#34511)
1.1.2¶
错误修复¶
在找到 符合所需 格式的 消息时 中断 AwaitMessageTrigger 执行 (#31803)
1.1.1¶
注意
此版本放弃了对 Python 3.7 的支持
杂项¶
移除 Python 3.7 支持 (#30963)
1.1.0¶
注意
此 provider 版本仅适用于 Airflow 2.4+，详情请参阅 Apache Airflow provider 支持策略。
杂项¶
提升 provider 中的最低 Airflow 版本 (#30917)
1.0.0¶
此 provider 的初始版本。