完善删除逻辑

src/main/java/zs/payment/messages/KafkaConsumer.java

@@ -73,7 +73,7 @@ public class KafkaConsumer {
      * @param messsage
      */
     @KafkaListener(
-        topics = "goods.undercarriage1",
+        topics = "goods.undercarriage",
         groupId = "pay2-group"
     )
     public void goodsUndercarriage(String messsage) {
@@ -97,7 +97,7 @@ public class KafkaConsumer {
      * @param messsage
      */
     @KafkaListener(
-        topics = "goods.on.sale1",
+        topics = "goods.on.sale",
         groupId = "pay2-group"
     )
     public void goodsOnSale(String messsage) {
@@ -121,7 +121,7 @@ public class KafkaConsumer {
      * @param messsage
      */
     @KafkaListener(
-        topics = "goods.delete1",
+        topics = "goods.delete",
         groupId = "pay2-group"
     )
     public void goodsDelete(String messsage) {
@@ -149,7 +149,7 @@ public class KafkaConsumer {
      * @param messsage
      */
     @KafkaListener(
-        topics = "goods.sync1",
+        topics = "goods.sync",
         groupId = "pay2-group"
     )
     @Transactional(rollbackFor = Exception.class)
@@ -375,7 +375,7 @@ public class KafkaConsumer {
      * @param orderSn
      */
     @KafkaListener(
-        topics = "order.delivery1",
+        topics = "order.delivery",
         groupId = "pay2-group"
     )
     public void goodsDelivery(String orderSn) {
@@ -392,7 +392,7 @@ public class KafkaConsumer {
      * 消息格式：{"uniacid":1, "gdId":123456, "mallid":100, "cates":[1,2,3]}
      */
     @KafkaListener(
-        topics = "commodity.procure1",
+        topics = "commodity.procure",
         groupId = "pay2-group"
     )
     public void commodityProcure(String message) {
@@ -420,7 +420,7 @@ public class KafkaConsumer {
      * 消息格式：{"uniacid":1, "goodsId":12345, "issupply":1, "cate":10, "storeid":789}
      */
     @KafkaListener(
-        topics = "commodity.fulloutput1",
+        topics = "commodity.fulloutput",
         groupId = "pay2-group"
     )
     public void fullOutputProcess(String message) {
@@ -455,7 +455,7 @@ public class KafkaConsumer {
      * 消息格式：{"total":100000, "pageSize":50}
      */
     @KafkaListener(
-        topics = "sync.qiyun.remain1",
+        topics = "sync.qiyun.remain",
         groupId = "pay2-group"
     )
     public void syncQiyunRemain(String message) {