This repository has been archived by the owner on Aug 23, 2024. It is now read-only.
Releases: astronomer/airflow-provider-kafka
Releases · astronomer/airflow-provider-kafka
0.2.2
Release adds the following functionality:
- kafka config dictionaries are now templated fields
- the
ConsumeFromTopicOperator
has an additional kwarg to accept a function applied to a batch of messages.
Contributors:
@oboki
@dylanbstorey
0.2.1
Change Log :
-
Added a new Deferrable Operator
EventTriggersFunction
. This operator is a re entrant sensor that triggers a callable after encountering a defined message type. listener_dag_function.py demonstrates its use on a FizzBuzz problem. -
Updates to documentation for clarity and correctness.
Contributors :
RC-0.2.1
Update __init__.py bumping version for release.
0.1.1
0.1.1
What's Changed
- Fix
bootstrap.servers
typo by @sergeyh in #5 - Add template fields to ProduceToTopicOperator by @sergeyh in #6
- add templating to consumer fields by @dylanbstorey in #7
- Update await_message.py by @dylanbstorey in #8
New Contributors
Full Changelog: 0.1.0...0.1.1
RC-0.1.1
Update __init__.py