v0.2.0

• The MQTT topic is now added as the kafka message key
• Updated dependencies and rust version
• Code refactoring

v0.1.0

This is the first public release of the mqtt-kafka-forwarding-service. A service that forwards messages from an MQTT broker to Kafka based on configurable topic mappings.

It comes with the following features:

• Guarantees At-Least-Once operations due to using manual acknowledgement in MQTT
• Optionally wraps MQTT payloads in a json object which preserves the original topic ({"topic": "foo/bar", "payload": "somebase64edpayload"}). Can be useful if later processing steps need the original MQTT topic (e.g. if some device-id is encoded in the topic but not repeated in the payload)
• Supports TLS for both MQTT and Kafka
• Supports username/password and client certificate authentication for both MQTT and Kafka

This release can be deployed using helm, as a docker image or as a rust static binary (see the project README for details for all methods).