Reprocessing the dropped messages using Kafka Extention

1

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?

Regards,
Nirmal Srinivasan

2

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:

<mqtt-to-kafka-mappings>
  <mqtt-to-kafka-mapping>
      <id>m-to-k</id>
      <cluster-id>cluster01</cluster-id>
      <mqtt-topic-filters>
          <mqtt-topic-filter>$dropped/#</mqtt-topic-filter>
      </mqtt-topic-filters>
      <kafka-topic>kafka-topic-for-dropped-msg</kafka-topic>
  </mqtt-to-kafka-mapping>
</mqtt-to-kafka-mappings>

Greetings,
Michael from the HiveMQ team

1 Like