azaroulas opened a new issue, #1371: URL: https://github.com/apache/pekko-connectors/issues/1371
We would like to use the Apache Pekko MQTT v5 connector in production, but we are currently blocked from doing so because MQTT 5 message properties are not exposed. While the underlying Paho MQTT v5 client provides access to MQTT 5 message properties (e.g. User Properties), these properties are currently dropped by the Pekko MQTT v5 connector. In the connector’s message model `org.apache.pekko.stream.connectors.mqttv5.model.MqttMessage`, only the topic and payload are exposed. MQTT 5 properties, such as User Properties, are not part of the model and therefore cannot be accessed by stream consumers. This prevents us from accessing required metadata (e.g. business identifiers and tracing information) that we transport via MQTT 5 User Properties and currently blocks us from using the MQTT v5 connector beyond a proof of concept. The underlying Paho `org.eclipse.paho.mqttv5.common.MqttMessage` already exposes all MQTT 5 properties via MqttProperties, but these are not propagated into the Pekko message model. We would like to adopt the MQTT v5 connector long-term and would be happy to contribute an implementation to expose MQTT 5 message properties (starting with User Properties), if there are no objections or design concerns from the maintainers. -- This is an automated message from the Apache Git Service. To respond to the message, please log on to GitHub and use the URL above to go to the specific comment. To unsubscribe, e-mail: [email protected] For queries about this service, please contact Infrastructure at: [email protected] --------------------------------------------------------------------- To unsubscribe, e-mail: [email protected] For additional commands, e-mail: [email protected]
