消费者关闭

src/main/java/com/uas/ps/product/sync/MessageConsumer.java

@@ -148,6 +148,7 @@ public class MessageConsumer {
                     }
                 }
             }).start();
+            consumer.close();
         }
     }
 }