The example is to show how to customize your MQTT message format
PayloadFormatter.java
src/main/resources/META-INF/services/org.apache.iotdb.db.mqtt.PayloadFormatter
: clean the file and put your implementation class name into the fileThen, in your server:
enable_mqtt_service=true
in iotdb-datanode.properties)mqtt_payload_formatter
in conf/iotdb-datanode.properties
as the value of getName() in your implementation