This is an automated email from the ASF dual-hosted git repository. zhoubo pushed a commit to branch master in repository https://gitbox.apache.org/repos/asf/rocketmq-connect.git
commit 4fdd8b2e20c4d815e7bd5c9cef13be89fcd56c02 Author: yuz10 <[email protected]> AuthorDate: Mon Feb 14 17:51:39 2022 +0800 Fix exception parsing redis command "set a 1010 px 1000" (#862) --- src/main/java/org/apache/rocketmq/connect/redis/parser/SetParser.java | 2 +- 1 file changed, 1 insertion(+), 1 deletion(-) diff --git a/src/main/java/org/apache/rocketmq/connect/redis/parser/SetParser.java b/src/main/java/org/apache/rocketmq/connect/redis/parser/SetParser.java index 4165cc2..c0afe71 100644 --- a/src/main/java/org/apache/rocketmq/connect/redis/parser/SetParser.java +++ b/src/main/java/org/apache/rocketmq/connect/redis/parser/SetParser.java @@ -41,7 +41,7 @@ public class SetParser extends AbstractCommandParser { builder.value(args[0]); int idx = 1; while (idx < args.length){ - String param = toRune(args[idx++]); + String param = args[idx++]; if (isEquals(param, RedisConstants.NX)) { builder.param(Options.REDIS_NX, Boolean.TRUE); } else if (isEquals(param, RedisConstants.XX)) {
