open kafka-fetcher and enable configs enableNativeJsonLog，The following error is reported in the log with Chinese

[ProgramCareer]

2021-09-28 20:04:13,099 - org.apache.skywalking.oap.server.analyzer.agent.kafka.provider.handler.LogHandler - 83 [KafkaConsumer-1-thread-2] ERROR [] - com.google.gson.stream.MalformedJsonException: Invalid escape sequence at line 1 column 791 path $.body.text.text
com.google.protobuf.InvalidProtocolBufferException: com.google.gson.stream.MalformedJsonException: Invalid escape sequence at line 1 column 791 path $.body.text.text
at com.google.protobuf.util.JsonFormat$ParserImpl.merge(JsonFormat.java:1347) ~[protobuf-java-util-3.12.4.jar:?]
at com.google.protobuf.util.JsonFormat$Parser.merge(JsonFormat.java:477) ~[protobuf-java-util-3.12.4.jar:?]
at org.apache.skywalking.oap.server.library.util.ProtoBufJsonUtils.fromJSON(ProtoBufJsonUtils.java:54) ~[library-util-8.7.0.jar:8.7.0]
at org.apache.skywalking.oap.server.analyzer.agent.kafka.provider.handler.JsonLogHandler.parseConsumerRecord(JsonLogHandler.java:52) ~[kafka-fetcher-plugin-8.7.0.jar:8.7.0]
at org.apache.skywalking.oap.server.analyzer.agent.kafka.provider.handler.LogHandler.handle(LogHandler.java:79) ~[kafka-fetcher-plugin-8.7.0.jar:8.7.0]
at org.apache.skywalking.oap.server.analyzer.agent.kafka.KafkaFetcherHandlerRegister.lambda$run$0(KafkaFetcherHandlerRegister.java:128) ~[kafka-fetcher-plugin-8.7.0.jar:8.7.0]
at java.util.concurrent.Executors$RunnableAdapter.call(Executors.java:511) [?:1.8.0_301]
at java.util.concurrent.FutureTask.run(FutureTask.java:266) [?:1.8.0_301]
at java.util.concurrent.ThreadPoolExecutor.runWorker(ThreadPoolExecutor.java:1149) [?:1.8.0_301]
at java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:624) [?:1.8.0_301]
at java.lang.Thread.run(Thread.java:748) [?:1.8.0_301]

[wu-sheng]

Are you suing some un-UTF8-encoding char?

[ProgramCareer]

There is Chinese in the log. I configured UTF-8 encoding in logback-spring.xml of the project, and specified - Dfile. encoding = UTF-8 when the project was started. There is no Chinese garbled code when consuming Kafka console, But it still made a mistake in the oapservice consumption Kafka data

[wu-sheng]

I think it is better to debug for getting this text, and write a UT for test locally. From my understanding, it is either protobuf bug or your encoding setup issue.

[ProgramCareer]

If the log is all in English, no error will be reported, and it can be parsed and reported es.I think this is caused by Chinese characters, but I'm sorry I don't know how to solve it

[wu-sheng]

This is open source project, you have to get your hands dirty. Try to read codes and coding. :)

[ProgramCareer]

OK, I will read the source code and try to find out the cause of the problem. Thank you again for your reply