fix:kafka中转过程修改

src/main/java/com/inodes/inodeskafka/service/SinanKzProcurementTaskResultTestKafkaService.java

@@ -24,7 +24,7 @@ public class SinanKzProcurementTaskResultTestKafkaService {
     @KafkaListener(topics ="${kafkaSinan.topicResult}",containerFactory = "kafkaLianjiaContainerFactory")
     public void topicResult(ConsumerRecord<String, Object> consumerRecord){
         log.info("返回审核结果消息:{}", consumerRecord.value());
-        kafkaTestTemplate.send(topicResult,consumerRecord.toString());
+        kafkaTestTemplate.send(topicResult,consumerRecord.value().toString());
         log.info("审核结果:{}", "转发测试服务器成功");
     }
 }

src/main/java/com/inodes/inodeskafka/service/SinanKzProcurementTaskTestKafkaService.java

@@ -31,7 +31,7 @@ public class SinanKzProcurementTaskTestKafkaService {
     @KafkaListener(topics ="${kafkaSinan.topicProducer}",containerFactory = "kafkaTestContainerFactory")
     public void topicProducerSim(ConsumerRecord<String, Object> consumerRecord){
         log.info("任务生成消息接收:{}", consumerRecord.value());
-        kafkaLianjiaTemplate.send(topicProducer,consumerRecord.toString());
+        kafkaLianjiaTemplate.send(topicProducer,consumerRecord.value().toString());
         log.info("任务生成消息接收:{}","发送司南工单成功！！");