diff --git a/iot-components/iot-nb-component/src/main/java/cc/iotkit/comp/nb/NBVerticle.java b/iot-components/iot-nb-component/src/main/java/cc/iotkit/comp/nb/NBVerticle.java index f3523f42..6f025c31 100644 --- a/iot-components/iot-nb-component/src/main/java/cc/iotkit/comp/nb/NBVerticle.java +++ b/iot-components/iot-nb-component/src/main/java/cc/iotkit/comp/nb/NBVerticle.java @@ -215,7 +215,7 @@ public class NBVerticle extends AbstractVerticle { throw new BizException(ErrCode.SEND_DESTINATION_NOT_FOUND); } Future result = endpoint.publish(topic, msg, - MqttQoS.AT_LEAST_ONCE, false, false); + MqttQoS.AT_MOST_ONCE, false, false); result.onFailure(e -> log.error("public topic failed", e)); result.onSuccess(integer -> log.info("publish success,topic:{},payload:{}", topic, msg)); }