search

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

queue/retry messages to Kafka #88

Closed fcrbat closed 1 month ago

fcrbat commented 3 months ago

Hi, is there way to queue/retry messages sent to kafka if the broker isn't available?

wind-c commented 2 months ago

Comqtt can send messages from the Broker to Kafka, but cannot send messages if the Broker is unavailable.

So, what are your specific application scenarios?

fcrbat commented 2 months ago

Lets say the broker is unvailable for a few minutes, is there a way to queue/retry the messages?

fcrbat commented 1 month ago

Found another way