commit e4869a5dbfcf37b16e87879ca7e31f26a30ded94
author yuz10 <845238369@qq.com> Mon Feb 14 16:28:38 2022 +0800
committer GitHub <noreply@github.com> Mon Feb 14 16:28:38 2022 +0800
tree 0eec0eb372f1141e4ffcdee29111a0b57625088b
parent 6b02a3e1b129a359dfcc77ab177c74fcca6fb48d

Fix exception parsing redis command "set a 1010 px 1000"

rocketmq-connect-redis/src/main/java/org/apache/rocketmq/connect/redis/parser/SetParser.java

diff --git a/rocketmq-connect-redis/src/main/java/org/apache/rocketmq/connect/redis/parser/SetParser.java b/rocketmq-connect-redis/src/main/java/org/apache/rocketmq/connect/redis/parser/SetParser.java
index 4165cc2..c0afe71 100644
--- a/rocketmq-connect-redis/src/main/java/org/apache/rocketmq/connect/redis/parser/SetParser.java
+++ b/rocketmq-connect-redis/src/main/java/org/apache/rocketmq/connect/redis/parser/SetParser.java
@@ -41,7 +41,7 @@
         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)) {