Reprocessing the dropped messages using Kafka Extention

Hi team,

If the dropped message are enabled in HiveMQ, is there a way to configure in the HiveMQ - Kafka Extension in a way that the dropped messages stored in the dropped messages topic are automatically reprocessed and sent to kafka from the HiveMQ-Kafka Extension?

Nirmal Srinivasan

Hi @Nirmal,

Yes that is possible. You just need an MQTT → Kafka transformer/mapping that consumes for example all dropped messages with “$dropped/#”. Here a possible config example with a mapping:


Michael from the HiveMQ team

1 Like