commit 4fdd8b2e20c4d815e7bd5c9cef13be89fcd56c02
author yuz10 <845238369@qq.com> Mon Feb 14 17:51:39 2022 +0800
committer GitHub <noreply@github.com> Mon Feb 14 17:51:39 2022 +0800
tree db9c74ecd986eda20dcf96eae91041b46637790b
parent 8a07d712a77b1f9dab78db0d52efba641a9bd4c5

Fix exception parsing redis command "set a 1010 px 1000" (#862)

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

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 @@
         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)) {