khoramism opened a new issue, #36446:
URL: https://github.com/apache/airflow/issues/36446

   ### 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](https://airflow.apache.org/docs/apache-airflow-providers-apache-kafka/stable/index.html),
 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](https://nats.io/) as well as 
[Kafka](https://kafka.apache.org/) 
   
   ### Related issues
   
   _No response_
   
   ### Are you willing to submit a PR?
   
   - [ ] Yes I am willing to submit a PR!
   
   ### Code of Conduct
   
   - [X] I agree to follow this project's [Code of 
Conduct](https://github.com/apache/airflow/blob/main/CODE_OF_CONDUCT.md)
   


-- 
This is an automated message from the Apache Git Service.
To respond to the message, please log on to GitHub and use the
URL above to go to the specific comment.

To unsubscribe, e-mail: [email protected]

For queries about this service, please contact Infrastructure at:
[email protected]

Reply via email to