wangli/axzo-log-plat
1
0
Fork 0
Code Issues Pull Requests Actions Packages Projects Releases Wiki Activity

Merge branch 'feature/slow_url_tly' into 'master'

Browse Source 
慢URL治理

See merge request universal/infrastructure/backend/axzo-log-plat!124
This commit is contained in:
田立勇 2023-09-14 03:31:05 +00:00
commit 5f16eeb0ea
1 changed files with 2 additions and 1 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

3
axzo-log-server/src/main/java/cn/axzo/log/platform/server/service/impl/LogSinkELKServiceImpl.java
View File

@ -5,6 +5,7 @@ import cn.axzo.log.platform.server.exception.BizException;
import cn.axzo.log.platform.server.service.LogSinkELKService;
import cn.axzo.log.platform.server.utils.JacksonCodecUtil;
import cn.axzo.log.platform.server.utils.SignUtil;
import com.alibaba.fastjson.JSON;
import com.alibaba.fastjson.JSONObject;
import com.fasterxml.jackson.core.JsonProcessingException;
import org.apache.kafka.clients.producer.Callback;
@ -88,7 +89,7 @@ public class LogSinkELKServiceImpl implements LogSinkELKService {
logger.warn("request sign is illegal,request sign={},server sign={}.", req.getSign(), sign);
throw new BizException("request sign is illegal.");
}
return JacksonCodecUtil.writeValueAsString(req);
return JSON.toJSONString(req);
} catch (Exception e) {
logger.warn("check sign or convert occur exception,msg={}.", e.getMessage());
throw new BizException(e.getMessage());