线程池 改写

device-service-infrastructure/src/main/java/com/hfln/device/infrastructure/config/TopicDealExecutor.java

@@ -16,7 +16,7 @@ public class TopicDealExecutor {
     private final KeyAffinityExecutor executor = KeyAffinityExecutor.newSerializingExecutor(
             PARALLELISM,
             QUEUE_SIZE,
-            "mqtt_sub-"
+            "mqtt_sub-%d"
     );
 
     public void submitTask(Object key, ThrowableRunnable<Exception> task) {