diff --git a/src/main/java/com/qniao/iot/IotMonitoringDataJob.java b/src/main/java/com/qniao/iot/IotMonitoringDataJob.java
index 679a742..4cdf7ed 100644
--- a/src/main/java/com/qniao/iot/IotMonitoringDataJob.java
+++ b/src/main/java/com/qniao/iot/IotMonitoringDataJob.java
@@ -100,7 +100,7 @@ public class IotMonitoringDataJob {
 
         final DataStream<MachineOutputCommand> stream = env
                 .addSource(new RMQSource<>(connectionConfig, ApolloConfig.getStr(ConfigConstant.SOURCE_RABBITMQ_QUEUE),
-                        true, new MachineOutputCommandDeserializationSchema())).setParallelism(1);
+                        false, new MachineOutputCommandDeserializationSchema())).setParallelism(1);
 
         // mac分组并进行工作时长的集合操作
         DataStream<DeviceMonitoringData> machineIotDataReceivedEventDataStream = stream