apache-airflow-providers-apache-kafka
更新日誌¶
1.7.0¶
注意
此供應商版本僅適用於 Airflow 2.9+，如 Apache Airflow 供應商支援政策 中所述。
錯誤修正¶
fix 'ConsumeFromTopicOperator' 即使 憑證錯誤 也不會 失敗 （#44307）
其他¶
將 供應商 中的 最低 Airflow 版本 提升 至 Airflow 2.9.0 （#44956）更新 多個 供應商 文件 中的 DAG 範例 連結 （#44034）
1.6.0¶
注意
此供應商版本僅適用於 Airflow 2.8+，如 Apache Airflow 供應商支援政策 中所述。
其他¶
將 供應商 中的 最低 Airflow 版本 提升 至 Airflow 2.8.0 （#41396）
1.5.0¶
新功能¶
新增 'delete_topic' 至 'KafkaAdminClientHook' （#40142）
錯誤修正¶
KafkaBaseHook 中的 預設 用戶端 （#40284）
其他¶
實作 每個供應商 的 測試 ，使用 最低限度的直接 依賴項 解析 （#39946）
1.4.1¶
錯誤修正¶
群組 ID 是 confluent_kafka 2.4.0+ 的 強制性 配置 選項 （#39559）
其他¶
更快的 'airflow_version' 導入 （#39552）簡化 'airflow_version' 導入 （#39497）
1.4.0¶
注意
此供應商版本僅適用於 Airflow 2.7+，如 Apache Airflow 供應商支援政策 中所述。
其他¶
將 供應商 中的 最低 Airflow 版本 提升 至 Airflow 2.7.0 （#39240）
1.3.1¶
錯誤修正¶
在 AwaitMessageTrigger 中 將 已消耗的 訊息 提供給 consumer.commit （#36272）在 子類別中 遵循 BaseHook 連線 欄位 方法 簽名 （#36086）
1.3.0¶
注意
此供應商版本僅適用於 Airflow 2.6+，如 Apache Airflow 供應商支援政策 中所述。
其他¶
將 供應商 中的 最低 Airflow 版本 提升 至 Airflow 2.6.0 （#36017）
1.2.0¶
注意
此供應商版本僅適用於 Airflow 2.5+，如 Apache Airflow 供應商支援政策 中所述。
錯誤修正¶
修正 錯字 （重複 單字 和 it's/its） （#33623）修正 Kafka 供應商的 最大 訊息 限制 錯誤 （#32926） （#33321）
其他¶
提升 供應商 的 最低 airflow 版本 （#34728）在 供應商 中 使用 'airflow.exceptions.AirflowException' （#34511）
1.1.0¶
注意
此供應商版本僅適用於 Airflow 2.4+，如 Apache Airflow 供應商支援政策 中所述。
其他¶
提升 供應商 中的 最低 Airflow 版本 （#30917）
1.0.0¶
供應商的初始版本。