[rocketmq-connect] branch master updated: update mns connectRecord data

[shenlin]

This is an automated email from the ASF dual-hosted git repository.

shenlin pushed a commit to branch master
in repository https://gitbox.apache.org/repos/asf/rocketmq-connect.git


The following commit(s) were added to refs/heads/master by this push:
     new baf9b24  update mns connectRecord data
baf9b24 is described below

commit baf9b248d48c9137b752ece63f558f0c3c74bf6e
Author: zh378814 <wb-zh378...@alibaba-inc.com>
AuthorDate: Mon Apr 18 16:28:55 2022 +0800

    update mns connectRecord data
---
 .../org/apache/rocketmq/connect/mns/source/MNSRecordConverImpl.java   | 4 ++--
 1 file changed, 2 insertions(+), 2 deletions(-)

diff --git 
a/connectors/aliyun/rocketmq-connect-mns/src/main/java/org/apache/rocketmq/connect/mns/source/MNSRecordConverImpl.java
 
b/connectors/aliyun/rocketmq-connect-mns/src/main/java/org/apache/rocketmq/connect/mns/source/MNSRecordConverImpl.java
index 078860f..1b2768f 100644
--- 
a/connectors/aliyun/rocketmq-connect-mns/src/main/java/org/apache/rocketmq/connect/mns/source/MNSRecordConverImpl.java
+++ 
b/connectors/aliyun/rocketmq-connect-mns/src/main/java/org/apache/rocketmq/connect/mns/source/MNSRecordConverImpl.java
@@ -33,8 +33,8 @@ public class MNSRecordConverImpl extends 
AbstractMNSRecordConvert {
         mnsDataMap.put("requestId", popMsg.getRequestId());
         mnsDataMap.put("messageId", popMsg.getMessageId());
         mnsDataMap.put("messageBody", messageBody);
-        connectRecord.setData(new 
Gson().toJson(mnsDataMap).getBytes(StandardCharsets.UTF_8));
-        connectRecord.setSchema(SchemaBuilder.bytes().build());
+        connectRecord.setData(new Gson().toJson(mnsDataMap));
+        connectRecord.setSchema(SchemaBuilder.string().build());
     }
 
     private JsonElement parseToJsonElement(String messageBodyValue) {