apache-airflow-providers-apache-kafka
Changelog¶
1.5.0¶
Features¶
Add 'delete_topic' to 'KafkaAdminClientHook' (#40142)
Bug Fixes¶
Default client in KafkaBaseHook (#40284)
Misc¶
implement per-provider tests with lowest-direct dependency resolution (#39946)
1.4.1¶
Bug Fixes¶
Group id is mandatory configuration option for confluent_kafka 2.4.0+ (#39559)
Misc¶
Faster 'airflow_version' imports (#39552)Simplify 'airflow_version' imports (#39497)
1.4.0¶
Note
This release of provider is only available for Airflow 2.7+ as explained in the Apache Airflow providers support policy.
Misc¶
Bump minimum Airflow version in providers to Airflow 2.7.0 (#39240)
1.3.1¶
Bug Fixes¶
Provide the consumed message to consumer.commit in AwaitMessageTrigger (#36272)Follow BaseHook connection fields method signature in child classes (#36086)
1.3.0¶
Note
This release of provider is only available for Airflow 2.6+ as explained in the Apache Airflow providers support policy.
Misc¶
Bump minimum Airflow version in providers to Airflow 2.6.0 (#36017)
1.2.0¶
Note
This release of provider is only available for Airflow 2.5+ as explained in the Apache Airflow providers support policy.
Bug Fixes¶
Fix typos (double words and it's/its) (#33623)Fixes the Kafka provider's max message limit error (#32926) (#33321)
Misc¶
Bump min airflow version of providers (#34728)Use 'airflow.exceptions.AirflowException' in providers (#34511)
1.1.2¶
Bug Fixes¶
Break AwaitMessageTrigger execution when finding a message with the desired format (#31803)
1.1.0¶
Note
This release of provider is only available for Airflow 2.4+ as explained in the Apache Airflow providers support policy.
Misc¶
Bump minimum Airflow version in providers (#30917)
1.0.0¶
Initial version of the provider.