Description
I think a lot of the teams already use nats as their message broker or streaming services and it would be a great Idea to have this as a part of the operators in airflow as well.
Use case/motivation
What I've been trying to achieve is the same process with the kafka, a Producer and a Consumer working together to implement or do something.
For example in my case I tried to use airflow as an Alerting system with Kafka, I'd do some stuff using different operators and at the end of the day, I'd just push all the anomalies or errors to a topic in Kafka, then I'd use Kafka and telegram or slack operators to consume from the topic and send the messages needed to a specific channel or ...
And It would just be a great idea to have the same process and support out of the box for Nats as well as Kafka
Related issues
No response
Are you willing to submit a PR?
Code of Conduct
Description
I think a lot of the teams already use nats as their message broker or streaming services and it would be a great Idea to have this as a part of the operators in airflow as well.
Use case/motivation
What I've been trying to achieve is the same process with the kafka, a Producer and a Consumer working together to implement or do something.
For example in my case I tried to use airflow as an Alerting system with Kafka, I'd do some stuff using different operators and at the end of the day, I'd just push all the anomalies or errors to a topic in Kafka, then I'd use Kafka and telegram or slack operators to consume from the topic and send the messages needed to a specific channel or ...
And It would just be a great idea to have the same process and support out of the box for Nats as well as Kafka
Related issues
No response
Are you willing to submit a PR?
Code of Conduct