fix: Kafka topic name 替换非法字符

ywt-platform-outpatient-rpc/src/main/java/com/ywt/outpatient/rpc/mq/KafkaMsgListener.java

@@ -35,7 +35,7 @@ public class KafkaMsgListener {
     @Autowired
     private CloudfilmProvider cloudfilmProvider;
 
-    @KafkaListener(topics = "/com.ywt.gapi.nat.NatService/refundNatOrderCallback", groupId = GROUP_NAME)
+    @KafkaListener(topics = "_com.ywt.gapi.nat.NatService_refundNatOrderCallback", groupId = GROUP_NAME)
     public void refundNatOrderCallback(ConsumerRecord<String, String> record, Acknowledgment ack) {
         logger.info("KafkaMsgListener#refundNatOrderCallback(topic={}, partition={}, value={}): 开始消费", record.topic(), record.partition(), record.value());
         try {
@@ -54,7 +54,7 @@ public class KafkaMsgListener {
         ack.acknowledge();
     }
 
-    @KafkaListener(topics = "/com.ywt.gapi.nat.NatService/payCallback", groupId = GROUP_NAME)
+    @KafkaListener(topics = "_com.ywt.gapi.nat.NatService_payCallback", groupId = GROUP_NAME)
     public void payCallback(ConsumerRecord<String, String> record, Acknowledgment ack) {
         logger.info("KafkaMsgListener#payCallback(topic={}, partition={}, value={}): 开始消费", record.topic(), record.partition(), record.value());
         try {
@@ -75,7 +75,7 @@ public class KafkaMsgListener {
     }
 
 
-    @KafkaListener(topics = "/com.ywt.gapi.third.cloudfilm.CloudfilmService/refundCheckResultOrderCallback", groupId = GROUP_NAME)
+    @KafkaListener(topics = "_com.ywt.gapi.third.cloudfilm.CloudfilmService_refundCheckResultOrderCallback", groupId = GROUP_NAME)
     public void refundCheckResultOrderCallback(ConsumerRecord<String, String> record, Acknowledgment ack) {
         logger.info("KafkaMsgListener#refundCheckResultOrderCallback(topic={}, partition={}, value={}): 开始消费", record.topic(), record.partition(), record.value());
         try {
@@ -95,7 +95,7 @@ public class KafkaMsgListener {
     }
 
 
-    @KafkaListener(topics = "/com.ywt.gapi.third.cloudfilm.CloudfilmService/payCallback", groupId = GROUP_NAME)
+    @KafkaListener(topics = "_com.ywt.gapi.third.cloudfilm.CloudfilmService_payCallback", groupId = GROUP_NAME)
     public void cloudfilmServicePayCallback(ConsumerRecord<String, String> record, Acknowledgment ack) {
         logger.info("KafkaMsgListener#cloudfilmServicePayCallback#payCallback(topic={}, partition={}, value={}): 开始消费", record.topic(), record.partition(), record.value());
         try {