issues
search
astronomer
/
airflow-provider-kafka
A provider package for kafka
Apache License 2.0
37
stars
16
forks
source link
issues
Newest
Newest
Most commented
Recently updated
Oldest
Least commented
Least recently updated
How to save sasl.password in a masked field in kafka connection?
#36
151N3
opened
3 months ago
3
Does not specify minimum required version of Airflow
#35
MorganRodgers
closed
1 year ago
2
Deprecation warning
#34
odaneau-astro
closed
1 year ago
1
Push data from ConsumeFromTopicOperator to XCom
#33
manojmanivannan
closed
1 year ago
4
updating produceToTopic produce method to allow custom headers
#32
nikitasharma1108
opened
1 year ago
2
ProduceToTopic does not allow to add custom headers to messages
#31
nikitasharma1108
opened
1 year ago
2
DevEx update
#30
dylanbstorey
closed
1 year ago
0
Unable to install airflow-provider-kafka package on Azure Cloud Airflow VM instance
#29
Bindu-yadav8
closed
1 year ago
1
Example not working on Airflow 2.0
#28
roalonsor
closed
1 year ago
1
Getting Errror while using ProduceToTopicOperator() operator
#27
krshashank963
closed
1 year ago
1
[help] access task instance in ProduceToTopicOperator producer_function
#26
rafaelleru
closed
1 year ago
6
Apply batch
#25
dylanbstorey
closed
1 year ago
0
Consumer function signature should be able to accept a list of messages.
#24
dylanbstorey
closed
1 year ago
0
Add `config` attributes to `template_fields`
#23
oboki
closed
1 year ago
1
Module docstrings tidy up
#22
josh-fell
closed
1 year ago
0
Unable to choose assign strategy for consumers
#21
BrandeeDev
closed
1 year ago
1
Kafka use connection_id as connectionString
#20
BrandeeDev
closed
1 year ago
1
Unable to install airflow-provider-kafka package in Azure Cloud Airflow VM instance
#19
Bindu-yadav8
closed
1 year ago
1
ProduceToTopicOperator execution_timeout
#18
AlexandrChikur
closed
1 year ago
3
Event triggers function operator
#17
TJaniF
closed
1 year ago
1
Event listener triggers a python callable. #15
#16
dylanbstorey
closed
1 year ago
0
Event listener triggers a python callable.
#15
dylanbstorey
closed
1 year ago
0
Trigger DagRun from Events
#14
dylanbstorey
closed
1 year ago
0
commit_cadence and apply_function documentation
#13
astro-stream
closed
1 year ago
0
Fix typo in README.md
#12
jankatins
closed
1 year ago
1
Can kafka config be a template field?
#11
Suresh-Nakkeran
closed
2 years ago
1
How to install the provider on a docker image
#10
ginwakeup
closed
2 years ago
5
One kafka consumer for messages?
#9
sherodtaylor
closed
2 years ago
4
Update await_message.py
#8
dylanbstorey
closed
2 years ago
0
add templating to consumer fields
#7
dylanbstorey
closed
2 years ago
0
Add template fields to ProduceToTopicOperator
#6
sergeyh
closed
2 years ago
0
Fix `bootstrap.servers` typo
#5
sergeyh
closed
2 years ago
1
cicd-setup
#4
dylanbstorey
closed
2 years ago
0
Add .circleci/config.yml
#3
dylanbstorey
closed
2 years ago
0
alpha bump
#2
dylanbstorey
closed
2 years ago
0
gitlab-ci-cd test
#1
dylanbstorey
closed
2 years ago
0