优化代码

java110

2021-09-01 85dceb0dd3e455082aed9c343dd76e675ff24d6e

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

@@ -71,6 +71,22 @@
        }
    }

    @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