You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@rocketmq.apache.org by sh...@apache.org on 2022/06/07 07:08:01 UTC
[rocketmq-connect] branch master updated: update mns connectRecord data
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...@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) {