Crate rmqtt_bridge_ingress_kafka 

Kafka ingress bridge plugin for RMQTT.

Consumes messages from Apache Kafka topics and publishes them as MQTT messages. Supports configurable topic mapping, consumer group management, and offset management.

Features

• Kafka consumer with configurable group ID and offset reset.
• MQTT QoS mapping for bridge reliability.
• Message format transformation (JSON, Avro, raw bytes).

Functions

register

register_named