diff --git a/src/main/java/com/knowledge/base/application/filter/LogFilter.java b/src/main/java/com/knowledge/base/application/filter/LogFilter.java index 85c87db..e2ffef3 100644 --- a/src/main/java/com/knowledge/base/application/filter/LogFilter.java +++ b/src/main/java/com/knowledge/base/application/filter/LogFilter.java @@ -45,6 +45,13 @@ public class LogFilter extends OncePerRequestFilter { ContentCachingRequestWrapper requestWrapper = new ContentCachingRequestWrapper(request); ContentCachingResponseWrapper responseWrapper = new ContentCachingResponseWrapper(response); + String accept = request.getHeader("Accept"); + String contentType = response.getContentType(); + if ((accept != null && accept.contains("text/event-stream")) + || (contentType != null && contentType.contains("text/event-stream"))) { + filterChain.doFilter(request, response); + return; + } if (!"Y".equalsIgnoreCase(dynamicConfig.getRecordMsgBody())) { filterChain.doFilter(requestWrapper, responseWrapper);