diff --git a/common/common-rest/src/main/java/org/apache/servicecomb/common/rest/codec/produce/ProduceEventStreamProcessor.java b/common/common-rest/src/main/java/org/apache/servicecomb/common/rest/codec/produce/ProduceEventStreamProcessor.java index 109a460cd9d..d1a436c834f 100644 --- a/common/common-rest/src/main/java/org/apache/servicecomb/common/rest/codec/produce/ProduceEventStreamProcessor.java +++ b/common/common-rest/src/main/java/org/apache/servicecomb/common/rest/codec/produce/ProduceEventStreamProcessor.java @@ -379,8 +379,10 @@ private void appendData(StringBuilder eventBuilder, List datas) throws Except throw new Exception("sse response data is null!"); } for (Object data : datas) { + String value = data instanceof String ? (String) data + : RestObjectMapperFactory.getRestObjectMapper().writeValueAsString(data); eventBuilder.append("data: ") - .append(RestObjectMapperFactory.getRestObjectMapper().writeValueAsString(data)) + .append(value) .append("\n"); } }