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 的初始版本。