Commit 029dfa39 by songyinghui

feat: log 日志

parent 122009ea
......@@ -23,6 +23,8 @@ public class InteractRecordMessageListener implements MessageListener<String, St
@Override
public void onMessage(ConsumerRecord<String, String> consumerRecord) {
String value = consumerRecord.value();
log.info("【InteractRecordMessageListener】处理埋点事件 {}", value);
InteractRecordMessageBO recordMessageBO = JSON.parseObject(value, InteractRecordMessageBO.class);
if (recordMessageBO == null) {
log.info("互动记录解析异常 {}", 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