优化代码

service-job/src/main/java/com/java110/job/kafka/JobServiceBean.java

@@ -13,4 +13,5 @@ public class JobServiceBean {
         return new JobServiceKafka();
     }
 
+
 }

service-job/src/main/java/com/java110/job/kafka/JobServiceKafka.java

@@ -71,6 +71,22 @@ public class JobServiceKafka extends BaseController {
         }
     }
 
+    @KafkaListener(topics = {"${kafka.hcGovTopic}"})
+    public void hcGovListen(ConsumerRecord<?, ?> record) {
+        logger.info("kafka的key: " + record.key());
+        logger.info("kafka的value: " + record.value().toString());
+        String orderInfo = record.value().toString();
+
+        try {
+            logger.debug("hcGovkafka 接收到数据", orderInfo);
+            //responseJson = jobServiceSMOImpl.service(businessServiceDataFlow);
+        } catch (Exception e) {
+            logger.error("请求订单异常", e);
+        } finally {
+
+        }
+    }
+
 
     /**
      * 这里预校验，请求报文中不能有 dataFlowId

service-job/src/main/resources/application-dev.yml

@@ -95,6 +95,7 @@ kafka:
     group:
       id: notifyBusinessStatus
     concurrency: 10
+  hcGovTopic: csxq
 
   producer:
     zookeeper: