feature request: provide a channel to the message queue(rabbitmq, kafka)

[sparkdevo]

We want to collect alarm messages from different monitoring systems through message queues, and then distribute them centrally with custom rules.