diff --git a/src/main/java/com/qniao/iot/IotMonitoringDataJob.java b/src/main/java/com/qniao/iot/IotMonitoringDataJob.java
index 4108c0b..d7638cd 100644
--- a/src/main/java/com/qniao/iot/IotMonitoringDataJob.java
+++ b/src/main/java/com/qniao/iot/IotMonitoringDataJob.java
@@ -427,7 +427,8 @@ public class IotMonitoringDataJob {
 
                             @Override
                             public String computeRoutingKey(DeviceMonitoringData data) {
-                                return null;
+
+                                return ApolloConfig.getStr(ConfigConstant.SINK_RABBITMQ_ROUTING_KEY);
                             }
 
                             @Override
diff --git a/src/main/java/com/qniao/iot/constant/ConfigConstant.java b/src/main/java/com/qniao/iot/constant/ConfigConstant.java
index 63a8975..46d39ac 100644
--- a/src/main/java/com/qniao/iot/constant/ConfigConstant.java
+++ b/src/main/java/com/qniao/iot/constant/ConfigConstant.java
@@ -39,4 +39,6 @@ public interface ConfigConstant {
     String SINK_RABBITMQ_PASSWORD = "sink.rabbitmq.password";
 
     String SINK_RABBITMQ_EXCHANGE = "sink.rabbitmq.exchange";
+
+    String SINK_RABBITMQ_ROUTING_KEY = "sink.rabbitmq.routingKey";
 }