wind-c / comqtt

A lightweight, high-performance go mqtt server(v3.0|v3.1.1|v5.0) supporting distributed cluster
MIT License
869 stars 50 forks source link

Persist messages to kafka #44

Closed perbu closed 11 months ago

perbu commented 11 months ago

Hello.

We're considering adding support to persist all MQTT topic matching a certain filter, to Kafka. Not sure if this is relevant for the project. If it is relevant for the project, let me know and we'll work together as we implement it according to your guidelines.

If not, which is perfectly fine, we'll just do it in a private fork.

All the best,

Per.

wind-c commented 11 months ago

Bridging messages to kafka is already supported, see plugin/bridge/kafka. If you find any problems or need to add any capabilities, please report back.

perbu commented 11 months ago

that was funny. thanks for pointing me the right way.