Commit 06ef32bc by libin

添加部分日志打印

parent ee138d4d
......@@ -151,7 +151,7 @@ public class ResourceService {
while (true) {
ConsumerRecords<String, String> records = consumer.poll(10000);//消费间隔单位:毫秒
for (ConsumerRecord<String, String> consumerRecord : records) {
logger.info(consumerRecord.key()+":"+consumerRecord.value()); // 消息key:taskid的值// 消息value:消息的json字符串
logger.info("消息队列返回内容:{"+consumerRecord.key()+":"+consumerRecord.value()+"}"); // 消息key:taskid的值// 消息value:消息的json字符串
try {
if("JJXX".equals(type)){
TbZhzxJjxx entity = parseJjxx(consumerRecord.value());
......
Markdown is supported
0% or
You are about to add 0 people to the discussion. Proceed with caution.
Finish editing this message first!
Please register or to comment