apache-airflow-providers-apache-kafka

Changelog

1.7.0

Note

This release of provider is only available for Airflow 2.9+ as explained in the Apache Airflow providers support policy.

Bug Fixes

  • fix 'ConsumeFromTopicOperator' does not fail even if wrong credentials (#44307)

Misc

  • Bump minimum Airflow version in providers to Airflow 2.9.0 (#44956)

  • Update DAG example links in multiple providers documents (#44034)

1.6.1

Bug Fixes

  • remove callable functions parameter from kafka operator template_fields (#42555)

1.6.0

Note

This release of provider is only available for Airflow 2.8+ as explained in the Apache Airflow providers support policy.

Misc

  • Bump minimum Airflow version in providers to Airflow 2.8.0 (#41396)

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.1

Note

This release dropped support for Python 3.7

Misc

  • Remove Python 3.7 support (#30963)

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.

Was this entry helpful?