You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@rocketmq.apache.org by zh...@apache.org on 2022/03/02 06:15:06 UTC
[rocketmq-connect] 08/10: Add 'connectors/rocketmq-connect-redis/' from commit '4fdd8b2e20c4d815e7bd5c9cef13be89fcd56c02'
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 fb6e0852880c6b37fe734b8a8048379e1489456a
Merge: 3f900aa 4fdd8b2
Author: odbozhou <87...@qq.com>
AuthorDate: Wed Mar 2 14:12:21 2022 +0800
Add 'connectors/rocketmq-connect-redis/' from commit '4fdd8b2e20c4d815e7bd5c9cef13be89fcd56c02'
git-subtree-dir: connectors/rocketmq-connect-redis
git-subtree-mainline: 3f900aab003d00885c97adfbbf8fb3aa9f8e3835
git-subtree-split: 4fdd8b2e20c4d815e7bd5c9cef13be89fcd56c02
connectors/rocketmq-connect-redis/README-CN.md | 19 +
connectors/rocketmq-connect-redis/README.md | 19 +
connectors/rocketmq-connect-redis/pom.xml | 208 ++++
.../rocketmq/connect/redis/common/Config.java | 237 +++++
.../rocketmq/connect/redis/common/Options.java | 124 +++
.../connect/redis/common/RedisConstants.java | 46 +
.../rocketmq/connect/redis/common/SyncMod.java | 37 +
.../redis/connector/RedisSourceConnector.java | 70 ++
.../connect/redis/connector/RedisSourceTask.java | 148 +++
.../connect/redis/converter/KVEntryConverter.java | 28 +
.../redis/converter/RedisEntryConverter.java | 134 +++
.../redis/converter/RedisPositionConverter.java | 54 +
.../redis/handler/DefaultRedisEventHandler.java | 174 +++
.../connect/redis/handler/RedisEventHandler.java | 72 ++
.../redis/parser/AbstractCommandParser.java | 82 ++
.../connect/redis/parser/AppendParser.java | 38 +
.../connect/redis/parser/BitFieldParser.java | 32 +
.../rocketmq/connect/redis/parser/BitOpParser.java | 41 +
.../connect/redis/parser/BrPopLPushParser.java | 41 +
.../connect/redis/parser/CommonParser.java | 117 +++
.../connect/redis/parser/DecrByParser.java | 38 +
.../rocketmq/connect/redis/parser/DecrParser.java | 32 +
.../redis/parser/DefaultRedisRdbParser.java | 197 ++++
.../rocketmq/connect/redis/parser/DelParser.java | 46 +
.../rocketmq/connect/redis/parser/EvalParser.java | 38 +
.../connect/redis/parser/EvalShaParser.java | 38 +
.../rocketmq/connect/redis/parser/ExecParser.java | 32 +
.../connect/redis/parser/ExpireAtParser.java | 38 +
.../connect/redis/parser/ExpireParser.java | 40 +
.../connect/redis/parser/FlushAllParser.java | 32 +
.../connect/redis/parser/FlushDbParser.java | 33 +
.../connect/redis/parser/GeoAddParser.java | 49 +
.../connect/redis/parser/GetsetParser.java | 37 +
.../rocketmq/connect/redis/parser/HDelParser.java | 41 +
.../connect/redis/parser/HIncrByParser.java | 41 +
.../connect/redis/parser/HSetNxParser.java | 37 +
.../rocketmq/connect/redis/parser/HSetParser.java | 37 +
.../rocketmq/connect/redis/parser/HmSetParser.java | 37 +
.../connect/redis/parser/IncrByParser.java | 38 +
.../rocketmq/connect/redis/parser/IncrParser.java | 32 +
.../rocketmq/connect/redis/parser/LPopParser.java | 32 +
.../rocketmq/connect/redis/parser/LPushParser.java | 41 +
.../connect/redis/parser/LPushXParser.java | 37 +
.../rocketmq/connect/redis/parser/LRemParser.java | 41 +
.../rocketmq/connect/redis/parser/LSetParser.java | 41 +
.../rocketmq/connect/redis/parser/LTrimParser.java | 41 +
.../connect/redis/parser/LinsertParser.java | 51 +
.../connect/redis/parser/MSetNxParser.java | 37 +
.../rocketmq/connect/redis/parser/MSetParser.java | 37 +
.../rocketmq/connect/redis/parser/MoveParser.java | 38 +
.../rocketmq/connect/redis/parser/MultiParser.java | 32 +
.../connect/redis/parser/PExpireAtParser.java | 38 +
.../connect/redis/parser/PExpireParser.java | 38 +
.../connect/redis/parser/PSetExParser.java | 41 +
.../rocketmq/connect/redis/parser/Parser.java | 24 +
.../connect/redis/parser/PersistParser.java | 32 +
.../rocketmq/connect/redis/parser/PfAddParser.java | 41 +
.../connect/redis/parser/PfCountParser.java | 37 +
.../connect/redis/parser/PfMergeParser.java | 41 +
.../connect/redis/parser/PublishParser.java | 37 +
.../connect/redis/parser/RPopLPushParser.java | 37 +
.../rocketmq/connect/redis/parser/RPopParser.java | 32 +
.../rocketmq/connect/redis/parser/RPushParser.java | 41 +
.../connect/redis/parser/RPushXParser.java | 37 +
.../connect/redis/parser/RedisRdbParser.java | 67 ++
.../connect/redis/parser/RenameNxParser.java | 37 +
.../connect/redis/parser/RenameParser.java | 37 +
.../connect/redis/parser/RestoreParser.java | 45 +
.../rocketmq/connect/redis/parser/SAddParser.java | 41 +
.../connect/redis/parser/SDiffStoreParser.java | 41 +
.../connect/redis/parser/SInterStoreParser.java | 41 +
.../rocketmq/connect/redis/parser/SMoveParser.java | 41 +
.../rocketmq/connect/redis/parser/SRemParser.java | 41 +
.../connect/redis/parser/SUnionStoreParser.java | 41 +
.../connect/redis/parser/ScriptParser.java | 32 +
.../connect/redis/parser/SelectParser.java | 38 +
.../connect/redis/parser/SetBitParser.java | 41 +
.../rocketmq/connect/redis/parser/SetExParser.java | 42 +
.../rocketmq/connect/redis/parser/SetNxParser.java | 37 +
.../rocketmq/connect/redis/parser/SetParser.java | 59 ++
.../connect/redis/parser/SetRangeParser.java | 41 +
.../rocketmq/connect/redis/parser/SortParser.java | 32 +
.../connect/redis/parser/SwapDbParser.java | 38 +
.../connect/redis/parser/UnLinkParser.java | 37 +
.../rocketmq/connect/redis/parser/XAckParser.java | 49 +
.../rocketmq/connect/redis/parser/XAddParser.java | 46 +
.../connect/redis/parser/XClaimParser.java | 88 ++
.../rocketmq/connect/redis/parser/XDelParser.java | 41 +
.../connect/redis/parser/XGroupParser.java | 32 +
.../connect/redis/parser/XSetIdParser.java | 37 +
.../rocketmq/connect/redis/parser/XTrimParser.java | 43 +
.../rocketmq/connect/redis/parser/ZAddParser.java | 69 ++
.../connect/redis/parser/ZIncrByParser.java | 41 +
.../connect/redis/parser/ZInterStoreParser.java | 37 +
.../connect/redis/parser/ZPopMaxParser.java | 38 +
.../connect/redis/parser/ZPopMinParser.java | 38 +
.../rocketmq/connect/redis/parser/ZRemParser.java | 41 +
.../connect/redis/parser/ZRemRangeByLexParser.java | 41 +
.../redis/parser/ZRemRangeByRankParser.java | 41 +
.../redis/parser/ZRemRangeByScoreParser.java | 41 +
.../connect/redis/parser/ZUnionStoreParser.java | 37 +
.../apache/rocketmq/connect/redis/pojo/Geo.java | 48 +
.../rocketmq/connect/redis/pojo/KVEntry.java | 71 ++
.../rocketmq/connect/redis/pojo/RedisEntry.java | 171 +++
.../rocketmq/connect/redis/pojo/RedisEvent.java | 59 ++
.../processor/DefaultRedisEventProcessor.java | 453 ++++++++
.../redis/processor/RedisClosedListener.java | 37 +
.../redis/processor/RedisEventListener.java | 121 +++
.../redis/processor/RedisEventProcessor.java | 40 +
.../processor/RedisEventProcessorCallback.java | 23 +
.../redis/processor/RedisExceptionListener.java | 44 +
.../connect/redis/util/ParseStringUtils.java | 54 +
.../connect/redis/util/PropertyToObjectUtils.java | 64 ++
.../rocketmq/redis/test/common/ConfigTest.java | 107 ++
.../rocketmq/redis/test/common/OptionsTest.java | 34 +
.../test/connector/RedisSourceConnectorTest.java | 35 +
.../redis/test/connector/RedisSourceTaskTest.java | 150 +++
.../test/converter/RedisEntryConverterTest.java | 118 +++
.../test/converter/RedisPositionConverterTest.java | 51 +
.../redis/test/handler/RedisEventHandlerTest.java | 468 +++++++++
.../rocketmq/redis/test/parser/ParserTest.java | 1108 ++++++++++++++++++++
.../apache/rocketmq/redis/test/pojo/GeoTest.java | 19 +
.../rocketmq/redis/test/pojo/KVEntryTest.java | 85 ++
.../rocketmq/redis/test/pojo/RedisEventTest.java | 33 +
.../redis/test/processor/ListenerTest.java | 135 +++
.../redis/test/processor/ProcessorTest.java | 193 ++++
.../redis/test/util/ParseStringUtilsTest.java | 45 +
.../redis/test/util/PropertyToObjectUtilsTest.java | 118 +++
.../style/copyright/Apache.xml | 23 +
.../style/copyright/profiles_settings.xml | 64 ++
.../style/rmq_checkstyle.xml | 134 +++
.../rocketmq-connect-redis/style/rmq_codeStyle.xml | 143 +++
132 files changed, 9375 insertions(+)
diff --cc connectors/rocketmq-connect-redis/README-CN.md
index 0000000,786b0d6..786b0d6
mode 000000,100644..100644
--- a/connectors/rocketmq-connect-redis/README-CN.md
+++ b/connectors/rocketmq-connect-redis/README-CN.md
diff --cc connectors/rocketmq-connect-redis/README.md
index 0000000,6da01d7..6da01d7
mode 000000,100644..100644
--- a/connectors/rocketmq-connect-redis/README.md
+++ b/connectors/rocketmq-connect-redis/README.md
diff --cc connectors/rocketmq-connect-redis/pom.xml
index 0000000,62f7950..62f7950
mode 000000,100644..100644
--- a/connectors/rocketmq-connect-redis/pom.xml
+++ b/connectors/rocketmq-connect-redis/pom.xml
diff --cc connectors/rocketmq-connect-redis/src/main/java/org/apache/rocketmq/connect/redis/common/Config.java
index 0000000,fe41075..fe41075
mode 000000,100644..100644
--- a/connectors/rocketmq-connect-redis/src/main/java/org/apache/rocketmq/connect/redis/common/Config.java
+++ b/connectors/rocketmq-connect-redis/src/main/java/org/apache/rocketmq/connect/redis/common/Config.java
diff --cc connectors/rocketmq-connect-redis/src/main/java/org/apache/rocketmq/connect/redis/common/Options.java
index 0000000,71cc07f..71cc07f
mode 000000,100644..100644
--- a/connectors/rocketmq-connect-redis/src/main/java/org/apache/rocketmq/connect/redis/common/Options.java
+++ b/connectors/rocketmq-connect-redis/src/main/java/org/apache/rocketmq/connect/redis/common/Options.java
diff --cc connectors/rocketmq-connect-redis/src/main/java/org/apache/rocketmq/connect/redis/common/RedisConstants.java
index 0000000,fd01c13..fd01c13
mode 000000,100644..100644
--- a/connectors/rocketmq-connect-redis/src/main/java/org/apache/rocketmq/connect/redis/common/RedisConstants.java
+++ b/connectors/rocketmq-connect-redis/src/main/java/org/apache/rocketmq/connect/redis/common/RedisConstants.java
diff --cc connectors/rocketmq-connect-redis/src/main/java/org/apache/rocketmq/connect/redis/common/SyncMod.java
index 0000000,9ad2093..9ad2093
mode 000000,100644..100644
--- a/connectors/rocketmq-connect-redis/src/main/java/org/apache/rocketmq/connect/redis/common/SyncMod.java
+++ b/connectors/rocketmq-connect-redis/src/main/java/org/apache/rocketmq/connect/redis/common/SyncMod.java
diff --cc connectors/rocketmq-connect-redis/src/main/java/org/apache/rocketmq/connect/redis/connector/RedisSourceConnector.java
index 0000000,fde9f92..fde9f92
mode 000000,100644..100644
--- a/connectors/rocketmq-connect-redis/src/main/java/org/apache/rocketmq/connect/redis/connector/RedisSourceConnector.java
+++ b/connectors/rocketmq-connect-redis/src/main/java/org/apache/rocketmq/connect/redis/connector/RedisSourceConnector.java
diff --cc connectors/rocketmq-connect-redis/src/main/java/org/apache/rocketmq/connect/redis/connector/RedisSourceTask.java
index 0000000,1b97836..1b97836
mode 000000,100644..100644
--- a/connectors/rocketmq-connect-redis/src/main/java/org/apache/rocketmq/connect/redis/connector/RedisSourceTask.java
+++ b/connectors/rocketmq-connect-redis/src/main/java/org/apache/rocketmq/connect/redis/connector/RedisSourceTask.java
diff --cc connectors/rocketmq-connect-redis/src/main/java/org/apache/rocketmq/connect/redis/converter/KVEntryConverter.java
index 0000000,de1b8ca..de1b8ca
mode 000000,100644..100644
--- a/connectors/rocketmq-connect-redis/src/main/java/org/apache/rocketmq/connect/redis/converter/KVEntryConverter.java
+++ b/connectors/rocketmq-connect-redis/src/main/java/org/apache/rocketmq/connect/redis/converter/KVEntryConverter.java
diff --cc connectors/rocketmq-connect-redis/src/main/java/org/apache/rocketmq/connect/redis/converter/RedisEntryConverter.java
index 0000000,23de075..23de075
mode 000000,100644..100644
--- a/connectors/rocketmq-connect-redis/src/main/java/org/apache/rocketmq/connect/redis/converter/RedisEntryConverter.java
+++ b/connectors/rocketmq-connect-redis/src/main/java/org/apache/rocketmq/connect/redis/converter/RedisEntryConverter.java
diff --cc connectors/rocketmq-connect-redis/src/main/java/org/apache/rocketmq/connect/redis/converter/RedisPositionConverter.java
index 0000000,37e9e98..37e9e98
mode 000000,100644..100644
--- a/connectors/rocketmq-connect-redis/src/main/java/org/apache/rocketmq/connect/redis/converter/RedisPositionConverter.java
+++ b/connectors/rocketmq-connect-redis/src/main/java/org/apache/rocketmq/connect/redis/converter/RedisPositionConverter.java
diff --cc connectors/rocketmq-connect-redis/src/main/java/org/apache/rocketmq/connect/redis/handler/DefaultRedisEventHandler.java
index 0000000,14362b9..14362b9
mode 000000,100644..100644
--- a/connectors/rocketmq-connect-redis/src/main/java/org/apache/rocketmq/connect/redis/handler/DefaultRedisEventHandler.java
+++ b/connectors/rocketmq-connect-redis/src/main/java/org/apache/rocketmq/connect/redis/handler/DefaultRedisEventHandler.java
diff --cc connectors/rocketmq-connect-redis/src/main/java/org/apache/rocketmq/connect/redis/handler/RedisEventHandler.java
index 0000000,6f93b2d..6f93b2d
mode 000000,100644..100644
--- a/connectors/rocketmq-connect-redis/src/main/java/org/apache/rocketmq/connect/redis/handler/RedisEventHandler.java
+++ b/connectors/rocketmq-connect-redis/src/main/java/org/apache/rocketmq/connect/redis/handler/RedisEventHandler.java
diff --cc connectors/rocketmq-connect-redis/src/main/java/org/apache/rocketmq/connect/redis/parser/AbstractCommandParser.java
index 0000000,bf67b7d..bf67b7d
mode 000000,100644..100644
--- a/connectors/rocketmq-connect-redis/src/main/java/org/apache/rocketmq/connect/redis/parser/AbstractCommandParser.java
+++ b/connectors/rocketmq-connect-redis/src/main/java/org/apache/rocketmq/connect/redis/parser/AbstractCommandParser.java
diff --cc connectors/rocketmq-connect-redis/src/main/java/org/apache/rocketmq/connect/redis/parser/AppendParser.java
index 0000000,67c5a76..67c5a76
mode 000000,100644..100644
--- a/connectors/rocketmq-connect-redis/src/main/java/org/apache/rocketmq/connect/redis/parser/AppendParser.java
+++ b/connectors/rocketmq-connect-redis/src/main/java/org/apache/rocketmq/connect/redis/parser/AppendParser.java
diff --cc connectors/rocketmq-connect-redis/src/main/java/org/apache/rocketmq/connect/redis/parser/BitFieldParser.java
index 0000000,55c7ce0..55c7ce0
mode 000000,100644..100644
--- a/connectors/rocketmq-connect-redis/src/main/java/org/apache/rocketmq/connect/redis/parser/BitFieldParser.java
+++ b/connectors/rocketmq-connect-redis/src/main/java/org/apache/rocketmq/connect/redis/parser/BitFieldParser.java
diff --cc connectors/rocketmq-connect-redis/src/main/java/org/apache/rocketmq/connect/redis/parser/BitOpParser.java
index 0000000,38b1b71..38b1b71
mode 000000,100644..100644
--- a/connectors/rocketmq-connect-redis/src/main/java/org/apache/rocketmq/connect/redis/parser/BitOpParser.java
+++ b/connectors/rocketmq-connect-redis/src/main/java/org/apache/rocketmq/connect/redis/parser/BitOpParser.java
diff --cc connectors/rocketmq-connect-redis/src/main/java/org/apache/rocketmq/connect/redis/parser/BrPopLPushParser.java
index 0000000,bd8a090..bd8a090
mode 000000,100644..100644
--- a/connectors/rocketmq-connect-redis/src/main/java/org/apache/rocketmq/connect/redis/parser/BrPopLPushParser.java
+++ b/connectors/rocketmq-connect-redis/src/main/java/org/apache/rocketmq/connect/redis/parser/BrPopLPushParser.java
diff --cc connectors/rocketmq-connect-redis/src/main/java/org/apache/rocketmq/connect/redis/parser/CommonParser.java
index 0000000,f8dca37..f8dca37
mode 000000,100644..100644
--- a/connectors/rocketmq-connect-redis/src/main/java/org/apache/rocketmq/connect/redis/parser/CommonParser.java
+++ b/connectors/rocketmq-connect-redis/src/main/java/org/apache/rocketmq/connect/redis/parser/CommonParser.java
diff --cc connectors/rocketmq-connect-redis/src/main/java/org/apache/rocketmq/connect/redis/parser/DecrByParser.java
index 0000000,edfad48..edfad48
mode 000000,100644..100644
--- a/connectors/rocketmq-connect-redis/src/main/java/org/apache/rocketmq/connect/redis/parser/DecrByParser.java
+++ b/connectors/rocketmq-connect-redis/src/main/java/org/apache/rocketmq/connect/redis/parser/DecrByParser.java
diff --cc connectors/rocketmq-connect-redis/src/main/java/org/apache/rocketmq/connect/redis/parser/DecrParser.java
index 0000000,c632603..c632603
mode 000000,100644..100644
--- a/connectors/rocketmq-connect-redis/src/main/java/org/apache/rocketmq/connect/redis/parser/DecrParser.java
+++ b/connectors/rocketmq-connect-redis/src/main/java/org/apache/rocketmq/connect/redis/parser/DecrParser.java
diff --cc connectors/rocketmq-connect-redis/src/main/java/org/apache/rocketmq/connect/redis/parser/DefaultRedisRdbParser.java
index 0000000,9a4c3ad..9a4c3ad
mode 000000,100644..100644
--- a/connectors/rocketmq-connect-redis/src/main/java/org/apache/rocketmq/connect/redis/parser/DefaultRedisRdbParser.java
+++ b/connectors/rocketmq-connect-redis/src/main/java/org/apache/rocketmq/connect/redis/parser/DefaultRedisRdbParser.java
diff --cc connectors/rocketmq-connect-redis/src/main/java/org/apache/rocketmq/connect/redis/parser/DelParser.java
index 0000000,17ae917..17ae917
mode 000000,100644..100644
--- a/connectors/rocketmq-connect-redis/src/main/java/org/apache/rocketmq/connect/redis/parser/DelParser.java
+++ b/connectors/rocketmq-connect-redis/src/main/java/org/apache/rocketmq/connect/redis/parser/DelParser.java
diff --cc connectors/rocketmq-connect-redis/src/main/java/org/apache/rocketmq/connect/redis/parser/EvalParser.java
index 0000000,deb36c1..deb36c1
mode 000000,100644..100644
--- a/connectors/rocketmq-connect-redis/src/main/java/org/apache/rocketmq/connect/redis/parser/EvalParser.java
+++ b/connectors/rocketmq-connect-redis/src/main/java/org/apache/rocketmq/connect/redis/parser/EvalParser.java
diff --cc connectors/rocketmq-connect-redis/src/main/java/org/apache/rocketmq/connect/redis/parser/EvalShaParser.java
index 0000000,38b564e..38b564e
mode 000000,100644..100644
--- a/connectors/rocketmq-connect-redis/src/main/java/org/apache/rocketmq/connect/redis/parser/EvalShaParser.java
+++ b/connectors/rocketmq-connect-redis/src/main/java/org/apache/rocketmq/connect/redis/parser/EvalShaParser.java
diff --cc connectors/rocketmq-connect-redis/src/main/java/org/apache/rocketmq/connect/redis/parser/ExecParser.java
index 0000000,0b48a59..0b48a59
mode 000000,100644..100644
--- a/connectors/rocketmq-connect-redis/src/main/java/org/apache/rocketmq/connect/redis/parser/ExecParser.java
+++ b/connectors/rocketmq-connect-redis/src/main/java/org/apache/rocketmq/connect/redis/parser/ExecParser.java
diff --cc connectors/rocketmq-connect-redis/src/main/java/org/apache/rocketmq/connect/redis/parser/ExpireAtParser.java
index 0000000,e04606c..e04606c
mode 000000,100644..100644
--- a/connectors/rocketmq-connect-redis/src/main/java/org/apache/rocketmq/connect/redis/parser/ExpireAtParser.java
+++ b/connectors/rocketmq-connect-redis/src/main/java/org/apache/rocketmq/connect/redis/parser/ExpireAtParser.java
diff --cc connectors/rocketmq-connect-redis/src/main/java/org/apache/rocketmq/connect/redis/parser/ExpireParser.java
index 0000000,7a47de7..7a47de7
mode 000000,100644..100644
--- a/connectors/rocketmq-connect-redis/src/main/java/org/apache/rocketmq/connect/redis/parser/ExpireParser.java
+++ b/connectors/rocketmq-connect-redis/src/main/java/org/apache/rocketmq/connect/redis/parser/ExpireParser.java
diff --cc connectors/rocketmq-connect-redis/src/main/java/org/apache/rocketmq/connect/redis/parser/FlushAllParser.java
index 0000000,7db9603..7db9603
mode 000000,100644..100644
--- a/connectors/rocketmq-connect-redis/src/main/java/org/apache/rocketmq/connect/redis/parser/FlushAllParser.java
+++ b/connectors/rocketmq-connect-redis/src/main/java/org/apache/rocketmq/connect/redis/parser/FlushAllParser.java
diff --cc connectors/rocketmq-connect-redis/src/main/java/org/apache/rocketmq/connect/redis/parser/FlushDbParser.java
index 0000000,908d456..908d456
mode 000000,100644..100644
--- a/connectors/rocketmq-connect-redis/src/main/java/org/apache/rocketmq/connect/redis/parser/FlushDbParser.java
+++ b/connectors/rocketmq-connect-redis/src/main/java/org/apache/rocketmq/connect/redis/parser/FlushDbParser.java
diff --cc connectors/rocketmq-connect-redis/src/main/java/org/apache/rocketmq/connect/redis/parser/GeoAddParser.java
index 0000000,7136787..7136787
mode 000000,100644..100644
--- a/connectors/rocketmq-connect-redis/src/main/java/org/apache/rocketmq/connect/redis/parser/GeoAddParser.java
+++ b/connectors/rocketmq-connect-redis/src/main/java/org/apache/rocketmq/connect/redis/parser/GeoAddParser.java
diff --cc connectors/rocketmq-connect-redis/src/main/java/org/apache/rocketmq/connect/redis/parser/GetsetParser.java
index 0000000,1c816fc..1c816fc
mode 000000,100644..100644
--- a/connectors/rocketmq-connect-redis/src/main/java/org/apache/rocketmq/connect/redis/parser/GetsetParser.java
+++ b/connectors/rocketmq-connect-redis/src/main/java/org/apache/rocketmq/connect/redis/parser/GetsetParser.java
diff --cc connectors/rocketmq-connect-redis/src/main/java/org/apache/rocketmq/connect/redis/parser/HDelParser.java
index 0000000,9b17875..9b17875
mode 000000,100644..100644
--- a/connectors/rocketmq-connect-redis/src/main/java/org/apache/rocketmq/connect/redis/parser/HDelParser.java
+++ b/connectors/rocketmq-connect-redis/src/main/java/org/apache/rocketmq/connect/redis/parser/HDelParser.java
diff --cc connectors/rocketmq-connect-redis/src/main/java/org/apache/rocketmq/connect/redis/parser/HIncrByParser.java
index 0000000,7547740..7547740
mode 000000,100644..100644
--- a/connectors/rocketmq-connect-redis/src/main/java/org/apache/rocketmq/connect/redis/parser/HIncrByParser.java
+++ b/connectors/rocketmq-connect-redis/src/main/java/org/apache/rocketmq/connect/redis/parser/HIncrByParser.java
diff --cc connectors/rocketmq-connect-redis/src/main/java/org/apache/rocketmq/connect/redis/parser/HSetNxParser.java
index 0000000,02268d0..02268d0
mode 000000,100644..100644
--- a/connectors/rocketmq-connect-redis/src/main/java/org/apache/rocketmq/connect/redis/parser/HSetNxParser.java
+++ b/connectors/rocketmq-connect-redis/src/main/java/org/apache/rocketmq/connect/redis/parser/HSetNxParser.java
diff --cc connectors/rocketmq-connect-redis/src/main/java/org/apache/rocketmq/connect/redis/parser/HSetParser.java
index 0000000,87dcc33..87dcc33
mode 000000,100644..100644
--- a/connectors/rocketmq-connect-redis/src/main/java/org/apache/rocketmq/connect/redis/parser/HSetParser.java
+++ b/connectors/rocketmq-connect-redis/src/main/java/org/apache/rocketmq/connect/redis/parser/HSetParser.java
diff --cc connectors/rocketmq-connect-redis/src/main/java/org/apache/rocketmq/connect/redis/parser/HmSetParser.java
index 0000000,4e317e4..4e317e4
mode 000000,100644..100644
--- a/connectors/rocketmq-connect-redis/src/main/java/org/apache/rocketmq/connect/redis/parser/HmSetParser.java
+++ b/connectors/rocketmq-connect-redis/src/main/java/org/apache/rocketmq/connect/redis/parser/HmSetParser.java
diff --cc connectors/rocketmq-connect-redis/src/main/java/org/apache/rocketmq/connect/redis/parser/IncrByParser.java
index 0000000,d691955..d691955
mode 000000,100644..100644
--- a/connectors/rocketmq-connect-redis/src/main/java/org/apache/rocketmq/connect/redis/parser/IncrByParser.java
+++ b/connectors/rocketmq-connect-redis/src/main/java/org/apache/rocketmq/connect/redis/parser/IncrByParser.java
diff --cc connectors/rocketmq-connect-redis/src/main/java/org/apache/rocketmq/connect/redis/parser/IncrParser.java
index 0000000,db0402b..db0402b
mode 000000,100644..100644
--- a/connectors/rocketmq-connect-redis/src/main/java/org/apache/rocketmq/connect/redis/parser/IncrParser.java
+++ b/connectors/rocketmq-connect-redis/src/main/java/org/apache/rocketmq/connect/redis/parser/IncrParser.java
diff --cc connectors/rocketmq-connect-redis/src/main/java/org/apache/rocketmq/connect/redis/parser/LPopParser.java
index 0000000,cc92668..cc92668
mode 000000,100644..100644
--- a/connectors/rocketmq-connect-redis/src/main/java/org/apache/rocketmq/connect/redis/parser/LPopParser.java
+++ b/connectors/rocketmq-connect-redis/src/main/java/org/apache/rocketmq/connect/redis/parser/LPopParser.java
diff --cc connectors/rocketmq-connect-redis/src/main/java/org/apache/rocketmq/connect/redis/parser/LPushParser.java
index 0000000,68672cf..68672cf
mode 000000,100644..100644
--- a/connectors/rocketmq-connect-redis/src/main/java/org/apache/rocketmq/connect/redis/parser/LPushParser.java
+++ b/connectors/rocketmq-connect-redis/src/main/java/org/apache/rocketmq/connect/redis/parser/LPushParser.java
diff --cc connectors/rocketmq-connect-redis/src/main/java/org/apache/rocketmq/connect/redis/parser/LPushXParser.java
index 0000000,bc301a5..bc301a5
mode 000000,100644..100644
--- a/connectors/rocketmq-connect-redis/src/main/java/org/apache/rocketmq/connect/redis/parser/LPushXParser.java
+++ b/connectors/rocketmq-connect-redis/src/main/java/org/apache/rocketmq/connect/redis/parser/LPushXParser.java
diff --cc connectors/rocketmq-connect-redis/src/main/java/org/apache/rocketmq/connect/redis/parser/LRemParser.java
index 0000000,6716061..6716061
mode 000000,100644..100644
--- a/connectors/rocketmq-connect-redis/src/main/java/org/apache/rocketmq/connect/redis/parser/LRemParser.java
+++ b/connectors/rocketmq-connect-redis/src/main/java/org/apache/rocketmq/connect/redis/parser/LRemParser.java
diff --cc connectors/rocketmq-connect-redis/src/main/java/org/apache/rocketmq/connect/redis/parser/LSetParser.java
index 0000000,be6fed4..be6fed4
mode 000000,100644..100644
--- a/connectors/rocketmq-connect-redis/src/main/java/org/apache/rocketmq/connect/redis/parser/LSetParser.java
+++ b/connectors/rocketmq-connect-redis/src/main/java/org/apache/rocketmq/connect/redis/parser/LSetParser.java
diff --cc connectors/rocketmq-connect-redis/src/main/java/org/apache/rocketmq/connect/redis/parser/LTrimParser.java
index 0000000,39a4386..39a4386
mode 000000,100644..100644
--- a/connectors/rocketmq-connect-redis/src/main/java/org/apache/rocketmq/connect/redis/parser/LTrimParser.java
+++ b/connectors/rocketmq-connect-redis/src/main/java/org/apache/rocketmq/connect/redis/parser/LTrimParser.java
diff --cc connectors/rocketmq-connect-redis/src/main/java/org/apache/rocketmq/connect/redis/parser/LinsertParser.java
index 0000000,c3d65b6..c3d65b6
mode 000000,100644..100644
--- a/connectors/rocketmq-connect-redis/src/main/java/org/apache/rocketmq/connect/redis/parser/LinsertParser.java
+++ b/connectors/rocketmq-connect-redis/src/main/java/org/apache/rocketmq/connect/redis/parser/LinsertParser.java
diff --cc connectors/rocketmq-connect-redis/src/main/java/org/apache/rocketmq/connect/redis/parser/MSetNxParser.java
index 0000000,8b13652..8b13652
mode 000000,100644..100644
--- a/connectors/rocketmq-connect-redis/src/main/java/org/apache/rocketmq/connect/redis/parser/MSetNxParser.java
+++ b/connectors/rocketmq-connect-redis/src/main/java/org/apache/rocketmq/connect/redis/parser/MSetNxParser.java
diff --cc connectors/rocketmq-connect-redis/src/main/java/org/apache/rocketmq/connect/redis/parser/MSetParser.java
index 0000000,34f9f11..34f9f11
mode 000000,100644..100644
--- a/connectors/rocketmq-connect-redis/src/main/java/org/apache/rocketmq/connect/redis/parser/MSetParser.java
+++ b/connectors/rocketmq-connect-redis/src/main/java/org/apache/rocketmq/connect/redis/parser/MSetParser.java
diff --cc connectors/rocketmq-connect-redis/src/main/java/org/apache/rocketmq/connect/redis/parser/MoveParser.java
index 0000000,0173086..0173086
mode 000000,100644..100644
--- a/connectors/rocketmq-connect-redis/src/main/java/org/apache/rocketmq/connect/redis/parser/MoveParser.java
+++ b/connectors/rocketmq-connect-redis/src/main/java/org/apache/rocketmq/connect/redis/parser/MoveParser.java
diff --cc connectors/rocketmq-connect-redis/src/main/java/org/apache/rocketmq/connect/redis/parser/MultiParser.java
index 0000000,cd32b16..cd32b16
mode 000000,100644..100644
--- a/connectors/rocketmq-connect-redis/src/main/java/org/apache/rocketmq/connect/redis/parser/MultiParser.java
+++ b/connectors/rocketmq-connect-redis/src/main/java/org/apache/rocketmq/connect/redis/parser/MultiParser.java
diff --cc connectors/rocketmq-connect-redis/src/main/java/org/apache/rocketmq/connect/redis/parser/PExpireAtParser.java
index 0000000,0390de0..0390de0
mode 000000,100644..100644
--- a/connectors/rocketmq-connect-redis/src/main/java/org/apache/rocketmq/connect/redis/parser/PExpireAtParser.java
+++ b/connectors/rocketmq-connect-redis/src/main/java/org/apache/rocketmq/connect/redis/parser/PExpireAtParser.java
diff --cc connectors/rocketmq-connect-redis/src/main/java/org/apache/rocketmq/connect/redis/parser/PExpireParser.java
index 0000000,efeee21..efeee21
mode 000000,100644..100644
--- a/connectors/rocketmq-connect-redis/src/main/java/org/apache/rocketmq/connect/redis/parser/PExpireParser.java
+++ b/connectors/rocketmq-connect-redis/src/main/java/org/apache/rocketmq/connect/redis/parser/PExpireParser.java
diff --cc connectors/rocketmq-connect-redis/src/main/java/org/apache/rocketmq/connect/redis/parser/PSetExParser.java
index 0000000,7ed476e..7ed476e
mode 000000,100644..100644
--- a/connectors/rocketmq-connect-redis/src/main/java/org/apache/rocketmq/connect/redis/parser/PSetExParser.java
+++ b/connectors/rocketmq-connect-redis/src/main/java/org/apache/rocketmq/connect/redis/parser/PSetExParser.java
diff --cc connectors/rocketmq-connect-redis/src/main/java/org/apache/rocketmq/connect/redis/parser/Parser.java
index 0000000,b9a4b12..b9a4b12
mode 000000,100644..100644
--- a/connectors/rocketmq-connect-redis/src/main/java/org/apache/rocketmq/connect/redis/parser/Parser.java
+++ b/connectors/rocketmq-connect-redis/src/main/java/org/apache/rocketmq/connect/redis/parser/Parser.java
diff --cc connectors/rocketmq-connect-redis/src/main/java/org/apache/rocketmq/connect/redis/parser/PersistParser.java
index 0000000,6bfb2d0..6bfb2d0
mode 000000,100644..100644
--- a/connectors/rocketmq-connect-redis/src/main/java/org/apache/rocketmq/connect/redis/parser/PersistParser.java
+++ b/connectors/rocketmq-connect-redis/src/main/java/org/apache/rocketmq/connect/redis/parser/PersistParser.java
diff --cc connectors/rocketmq-connect-redis/src/main/java/org/apache/rocketmq/connect/redis/parser/PfAddParser.java
index 0000000,51cfda2..51cfda2
mode 000000,100644..100644
--- a/connectors/rocketmq-connect-redis/src/main/java/org/apache/rocketmq/connect/redis/parser/PfAddParser.java
+++ b/connectors/rocketmq-connect-redis/src/main/java/org/apache/rocketmq/connect/redis/parser/PfAddParser.java
diff --cc connectors/rocketmq-connect-redis/src/main/java/org/apache/rocketmq/connect/redis/parser/PfCountParser.java
index 0000000,fe674d9..fe674d9
mode 000000,100644..100644
--- a/connectors/rocketmq-connect-redis/src/main/java/org/apache/rocketmq/connect/redis/parser/PfCountParser.java
+++ b/connectors/rocketmq-connect-redis/src/main/java/org/apache/rocketmq/connect/redis/parser/PfCountParser.java
diff --cc connectors/rocketmq-connect-redis/src/main/java/org/apache/rocketmq/connect/redis/parser/PfMergeParser.java
index 0000000,650c75b..650c75b
mode 000000,100644..100644
--- a/connectors/rocketmq-connect-redis/src/main/java/org/apache/rocketmq/connect/redis/parser/PfMergeParser.java
+++ b/connectors/rocketmq-connect-redis/src/main/java/org/apache/rocketmq/connect/redis/parser/PfMergeParser.java
diff --cc connectors/rocketmq-connect-redis/src/main/java/org/apache/rocketmq/connect/redis/parser/PublishParser.java
index 0000000,0d5d235..0d5d235
mode 000000,100644..100644
--- a/connectors/rocketmq-connect-redis/src/main/java/org/apache/rocketmq/connect/redis/parser/PublishParser.java
+++ b/connectors/rocketmq-connect-redis/src/main/java/org/apache/rocketmq/connect/redis/parser/PublishParser.java
diff --cc connectors/rocketmq-connect-redis/src/main/java/org/apache/rocketmq/connect/redis/parser/RPopLPushParser.java
index 0000000,38edce3..38edce3
mode 000000,100644..100644
--- a/connectors/rocketmq-connect-redis/src/main/java/org/apache/rocketmq/connect/redis/parser/RPopLPushParser.java
+++ b/connectors/rocketmq-connect-redis/src/main/java/org/apache/rocketmq/connect/redis/parser/RPopLPushParser.java
diff --cc connectors/rocketmq-connect-redis/src/main/java/org/apache/rocketmq/connect/redis/parser/RPopParser.java
index 0000000,85f122a..85f122a
mode 000000,100644..100644
--- a/connectors/rocketmq-connect-redis/src/main/java/org/apache/rocketmq/connect/redis/parser/RPopParser.java
+++ b/connectors/rocketmq-connect-redis/src/main/java/org/apache/rocketmq/connect/redis/parser/RPopParser.java
diff --cc connectors/rocketmq-connect-redis/src/main/java/org/apache/rocketmq/connect/redis/parser/RPushParser.java
index 0000000,8824d0b..8824d0b
mode 000000,100644..100644
--- a/connectors/rocketmq-connect-redis/src/main/java/org/apache/rocketmq/connect/redis/parser/RPushParser.java
+++ b/connectors/rocketmq-connect-redis/src/main/java/org/apache/rocketmq/connect/redis/parser/RPushParser.java
diff --cc connectors/rocketmq-connect-redis/src/main/java/org/apache/rocketmq/connect/redis/parser/RPushXParser.java
index 0000000,de2d21b..de2d21b
mode 000000,100644..100644
--- a/connectors/rocketmq-connect-redis/src/main/java/org/apache/rocketmq/connect/redis/parser/RPushXParser.java
+++ b/connectors/rocketmq-connect-redis/src/main/java/org/apache/rocketmq/connect/redis/parser/RPushXParser.java
diff --cc connectors/rocketmq-connect-redis/src/main/java/org/apache/rocketmq/connect/redis/parser/RedisRdbParser.java
index 0000000,fa4e46a..fa4e46a
mode 000000,100644..100644
--- a/connectors/rocketmq-connect-redis/src/main/java/org/apache/rocketmq/connect/redis/parser/RedisRdbParser.java
+++ b/connectors/rocketmq-connect-redis/src/main/java/org/apache/rocketmq/connect/redis/parser/RedisRdbParser.java
diff --cc connectors/rocketmq-connect-redis/src/main/java/org/apache/rocketmq/connect/redis/parser/RenameNxParser.java
index 0000000,14f4c4f..14f4c4f
mode 000000,100644..100644
--- a/connectors/rocketmq-connect-redis/src/main/java/org/apache/rocketmq/connect/redis/parser/RenameNxParser.java
+++ b/connectors/rocketmq-connect-redis/src/main/java/org/apache/rocketmq/connect/redis/parser/RenameNxParser.java
diff --cc connectors/rocketmq-connect-redis/src/main/java/org/apache/rocketmq/connect/redis/parser/RenameParser.java
index 0000000,9de8fe3..9de8fe3
mode 000000,100644..100644
--- a/connectors/rocketmq-connect-redis/src/main/java/org/apache/rocketmq/connect/redis/parser/RenameParser.java
+++ b/connectors/rocketmq-connect-redis/src/main/java/org/apache/rocketmq/connect/redis/parser/RenameParser.java
diff --cc connectors/rocketmq-connect-redis/src/main/java/org/apache/rocketmq/connect/redis/parser/RestoreParser.java
index 0000000,53a4569..53a4569
mode 000000,100644..100644
--- a/connectors/rocketmq-connect-redis/src/main/java/org/apache/rocketmq/connect/redis/parser/RestoreParser.java
+++ b/connectors/rocketmq-connect-redis/src/main/java/org/apache/rocketmq/connect/redis/parser/RestoreParser.java
diff --cc connectors/rocketmq-connect-redis/src/main/java/org/apache/rocketmq/connect/redis/parser/SAddParser.java
index 0000000,bb89eff..bb89eff
mode 000000,100644..100644
--- a/connectors/rocketmq-connect-redis/src/main/java/org/apache/rocketmq/connect/redis/parser/SAddParser.java
+++ b/connectors/rocketmq-connect-redis/src/main/java/org/apache/rocketmq/connect/redis/parser/SAddParser.java
diff --cc connectors/rocketmq-connect-redis/src/main/java/org/apache/rocketmq/connect/redis/parser/SDiffStoreParser.java
index 0000000,dc5ca3e..dc5ca3e
mode 000000,100644..100644
--- a/connectors/rocketmq-connect-redis/src/main/java/org/apache/rocketmq/connect/redis/parser/SDiffStoreParser.java
+++ b/connectors/rocketmq-connect-redis/src/main/java/org/apache/rocketmq/connect/redis/parser/SDiffStoreParser.java
diff --cc connectors/rocketmq-connect-redis/src/main/java/org/apache/rocketmq/connect/redis/parser/SInterStoreParser.java
index 0000000,be52db7..be52db7
mode 000000,100644..100644
--- a/connectors/rocketmq-connect-redis/src/main/java/org/apache/rocketmq/connect/redis/parser/SInterStoreParser.java
+++ b/connectors/rocketmq-connect-redis/src/main/java/org/apache/rocketmq/connect/redis/parser/SInterStoreParser.java
diff --cc connectors/rocketmq-connect-redis/src/main/java/org/apache/rocketmq/connect/redis/parser/SMoveParser.java
index 0000000,62007bb..62007bb
mode 000000,100644..100644
--- a/connectors/rocketmq-connect-redis/src/main/java/org/apache/rocketmq/connect/redis/parser/SMoveParser.java
+++ b/connectors/rocketmq-connect-redis/src/main/java/org/apache/rocketmq/connect/redis/parser/SMoveParser.java
diff --cc connectors/rocketmq-connect-redis/src/main/java/org/apache/rocketmq/connect/redis/parser/SRemParser.java
index 0000000,f51ad00..f51ad00
mode 000000,100644..100644
--- a/connectors/rocketmq-connect-redis/src/main/java/org/apache/rocketmq/connect/redis/parser/SRemParser.java
+++ b/connectors/rocketmq-connect-redis/src/main/java/org/apache/rocketmq/connect/redis/parser/SRemParser.java
diff --cc connectors/rocketmq-connect-redis/src/main/java/org/apache/rocketmq/connect/redis/parser/SUnionStoreParser.java
index 0000000,d821aba..d821aba
mode 000000,100644..100644
--- a/connectors/rocketmq-connect-redis/src/main/java/org/apache/rocketmq/connect/redis/parser/SUnionStoreParser.java
+++ b/connectors/rocketmq-connect-redis/src/main/java/org/apache/rocketmq/connect/redis/parser/SUnionStoreParser.java
diff --cc connectors/rocketmq-connect-redis/src/main/java/org/apache/rocketmq/connect/redis/parser/ScriptParser.java
index 0000000,746edb2..746edb2
mode 000000,100644..100644
--- a/connectors/rocketmq-connect-redis/src/main/java/org/apache/rocketmq/connect/redis/parser/ScriptParser.java
+++ b/connectors/rocketmq-connect-redis/src/main/java/org/apache/rocketmq/connect/redis/parser/ScriptParser.java
diff --cc connectors/rocketmq-connect-redis/src/main/java/org/apache/rocketmq/connect/redis/parser/SelectParser.java
index 0000000,a6ba72f..a6ba72f
mode 000000,100644..100644
--- a/connectors/rocketmq-connect-redis/src/main/java/org/apache/rocketmq/connect/redis/parser/SelectParser.java
+++ b/connectors/rocketmq-connect-redis/src/main/java/org/apache/rocketmq/connect/redis/parser/SelectParser.java
diff --cc connectors/rocketmq-connect-redis/src/main/java/org/apache/rocketmq/connect/redis/parser/SetBitParser.java
index 0000000,b7b9495..b7b9495
mode 000000,100644..100644
--- a/connectors/rocketmq-connect-redis/src/main/java/org/apache/rocketmq/connect/redis/parser/SetBitParser.java
+++ b/connectors/rocketmq-connect-redis/src/main/java/org/apache/rocketmq/connect/redis/parser/SetBitParser.java
diff --cc connectors/rocketmq-connect-redis/src/main/java/org/apache/rocketmq/connect/redis/parser/SetExParser.java
index 0000000,4c41260..4c41260
mode 000000,100644..100644
--- a/connectors/rocketmq-connect-redis/src/main/java/org/apache/rocketmq/connect/redis/parser/SetExParser.java
+++ b/connectors/rocketmq-connect-redis/src/main/java/org/apache/rocketmq/connect/redis/parser/SetExParser.java
diff --cc connectors/rocketmq-connect-redis/src/main/java/org/apache/rocketmq/connect/redis/parser/SetNxParser.java
index 0000000,ba784b0..ba784b0
mode 000000,100644..100644
--- a/connectors/rocketmq-connect-redis/src/main/java/org/apache/rocketmq/connect/redis/parser/SetNxParser.java
+++ b/connectors/rocketmq-connect-redis/src/main/java/org/apache/rocketmq/connect/redis/parser/SetNxParser.java
diff --cc connectors/rocketmq-connect-redis/src/main/java/org/apache/rocketmq/connect/redis/parser/SetParser.java
index 0000000,c0afe71..c0afe71
mode 000000,100644..100644
--- a/connectors/rocketmq-connect-redis/src/main/java/org/apache/rocketmq/connect/redis/parser/SetParser.java
+++ b/connectors/rocketmq-connect-redis/src/main/java/org/apache/rocketmq/connect/redis/parser/SetParser.java
diff --cc connectors/rocketmq-connect-redis/src/main/java/org/apache/rocketmq/connect/redis/parser/SetRangeParser.java
index 0000000,61b3c39..61b3c39
mode 000000,100644..100644
--- a/connectors/rocketmq-connect-redis/src/main/java/org/apache/rocketmq/connect/redis/parser/SetRangeParser.java
+++ b/connectors/rocketmq-connect-redis/src/main/java/org/apache/rocketmq/connect/redis/parser/SetRangeParser.java
diff --cc connectors/rocketmq-connect-redis/src/main/java/org/apache/rocketmq/connect/redis/parser/SortParser.java
index 0000000,0888917..0888917
mode 000000,100644..100644
--- a/connectors/rocketmq-connect-redis/src/main/java/org/apache/rocketmq/connect/redis/parser/SortParser.java
+++ b/connectors/rocketmq-connect-redis/src/main/java/org/apache/rocketmq/connect/redis/parser/SortParser.java
diff --cc connectors/rocketmq-connect-redis/src/main/java/org/apache/rocketmq/connect/redis/parser/SwapDbParser.java
index 0000000,27d7a33..27d7a33
mode 000000,100644..100644
--- a/connectors/rocketmq-connect-redis/src/main/java/org/apache/rocketmq/connect/redis/parser/SwapDbParser.java
+++ b/connectors/rocketmq-connect-redis/src/main/java/org/apache/rocketmq/connect/redis/parser/SwapDbParser.java
diff --cc connectors/rocketmq-connect-redis/src/main/java/org/apache/rocketmq/connect/redis/parser/UnLinkParser.java
index 0000000,6ee98ce..6ee98ce
mode 000000,100644..100644
--- a/connectors/rocketmq-connect-redis/src/main/java/org/apache/rocketmq/connect/redis/parser/UnLinkParser.java
+++ b/connectors/rocketmq-connect-redis/src/main/java/org/apache/rocketmq/connect/redis/parser/UnLinkParser.java
diff --cc connectors/rocketmq-connect-redis/src/main/java/org/apache/rocketmq/connect/redis/parser/XAckParser.java
index 0000000,7c2e2c9..7c2e2c9
mode 000000,100644..100644
--- a/connectors/rocketmq-connect-redis/src/main/java/org/apache/rocketmq/connect/redis/parser/XAckParser.java
+++ b/connectors/rocketmq-connect-redis/src/main/java/org/apache/rocketmq/connect/redis/parser/XAckParser.java
diff --cc connectors/rocketmq-connect-redis/src/main/java/org/apache/rocketmq/connect/redis/parser/XAddParser.java
index 0000000,755c267..755c267
mode 000000,100644..100644
--- a/connectors/rocketmq-connect-redis/src/main/java/org/apache/rocketmq/connect/redis/parser/XAddParser.java
+++ b/connectors/rocketmq-connect-redis/src/main/java/org/apache/rocketmq/connect/redis/parser/XAddParser.java
diff --cc connectors/rocketmq-connect-redis/src/main/java/org/apache/rocketmq/connect/redis/parser/XClaimParser.java
index 0000000,d3a2aa0..d3a2aa0
mode 000000,100644..100644
--- a/connectors/rocketmq-connect-redis/src/main/java/org/apache/rocketmq/connect/redis/parser/XClaimParser.java
+++ b/connectors/rocketmq-connect-redis/src/main/java/org/apache/rocketmq/connect/redis/parser/XClaimParser.java
diff --cc connectors/rocketmq-connect-redis/src/main/java/org/apache/rocketmq/connect/redis/parser/XDelParser.java
index 0000000,f1dcefa..f1dcefa
mode 000000,100644..100644
--- a/connectors/rocketmq-connect-redis/src/main/java/org/apache/rocketmq/connect/redis/parser/XDelParser.java
+++ b/connectors/rocketmq-connect-redis/src/main/java/org/apache/rocketmq/connect/redis/parser/XDelParser.java
diff --cc connectors/rocketmq-connect-redis/src/main/java/org/apache/rocketmq/connect/redis/parser/XGroupParser.java
index 0000000,5495270..5495270
mode 000000,100644..100644
--- a/connectors/rocketmq-connect-redis/src/main/java/org/apache/rocketmq/connect/redis/parser/XGroupParser.java
+++ b/connectors/rocketmq-connect-redis/src/main/java/org/apache/rocketmq/connect/redis/parser/XGroupParser.java
diff --cc connectors/rocketmq-connect-redis/src/main/java/org/apache/rocketmq/connect/redis/parser/XSetIdParser.java
index 0000000,2af95c3..2af95c3
mode 000000,100644..100644
--- a/connectors/rocketmq-connect-redis/src/main/java/org/apache/rocketmq/connect/redis/parser/XSetIdParser.java
+++ b/connectors/rocketmq-connect-redis/src/main/java/org/apache/rocketmq/connect/redis/parser/XSetIdParser.java
diff --cc connectors/rocketmq-connect-redis/src/main/java/org/apache/rocketmq/connect/redis/parser/XTrimParser.java
index 0000000,86a85b6..86a85b6
mode 000000,100644..100644
--- a/connectors/rocketmq-connect-redis/src/main/java/org/apache/rocketmq/connect/redis/parser/XTrimParser.java
+++ b/connectors/rocketmq-connect-redis/src/main/java/org/apache/rocketmq/connect/redis/parser/XTrimParser.java
diff --cc connectors/rocketmq-connect-redis/src/main/java/org/apache/rocketmq/connect/redis/parser/ZAddParser.java
index 0000000,555aaf5..555aaf5
mode 000000,100644..100644
--- a/connectors/rocketmq-connect-redis/src/main/java/org/apache/rocketmq/connect/redis/parser/ZAddParser.java
+++ b/connectors/rocketmq-connect-redis/src/main/java/org/apache/rocketmq/connect/redis/parser/ZAddParser.java
diff --cc connectors/rocketmq-connect-redis/src/main/java/org/apache/rocketmq/connect/redis/parser/ZIncrByParser.java
index 0000000,6bbf0d5..6bbf0d5
mode 000000,100644..100644
--- a/connectors/rocketmq-connect-redis/src/main/java/org/apache/rocketmq/connect/redis/parser/ZIncrByParser.java
+++ b/connectors/rocketmq-connect-redis/src/main/java/org/apache/rocketmq/connect/redis/parser/ZIncrByParser.java
diff --cc connectors/rocketmq-connect-redis/src/main/java/org/apache/rocketmq/connect/redis/parser/ZInterStoreParser.java
index 0000000,9c8382e..9c8382e
mode 000000,100644..100644
--- a/connectors/rocketmq-connect-redis/src/main/java/org/apache/rocketmq/connect/redis/parser/ZInterStoreParser.java
+++ b/connectors/rocketmq-connect-redis/src/main/java/org/apache/rocketmq/connect/redis/parser/ZInterStoreParser.java
diff --cc connectors/rocketmq-connect-redis/src/main/java/org/apache/rocketmq/connect/redis/parser/ZPopMaxParser.java
index 0000000,d4b4ff0..d4b4ff0
mode 000000,100644..100644
--- a/connectors/rocketmq-connect-redis/src/main/java/org/apache/rocketmq/connect/redis/parser/ZPopMaxParser.java
+++ b/connectors/rocketmq-connect-redis/src/main/java/org/apache/rocketmq/connect/redis/parser/ZPopMaxParser.java
diff --cc connectors/rocketmq-connect-redis/src/main/java/org/apache/rocketmq/connect/redis/parser/ZPopMinParser.java
index 0000000,070d2da..070d2da
mode 000000,100644..100644
--- a/connectors/rocketmq-connect-redis/src/main/java/org/apache/rocketmq/connect/redis/parser/ZPopMinParser.java
+++ b/connectors/rocketmq-connect-redis/src/main/java/org/apache/rocketmq/connect/redis/parser/ZPopMinParser.java
diff --cc connectors/rocketmq-connect-redis/src/main/java/org/apache/rocketmq/connect/redis/parser/ZRemParser.java
index 0000000,775a646..775a646
mode 000000,100644..100644
--- a/connectors/rocketmq-connect-redis/src/main/java/org/apache/rocketmq/connect/redis/parser/ZRemParser.java
+++ b/connectors/rocketmq-connect-redis/src/main/java/org/apache/rocketmq/connect/redis/parser/ZRemParser.java
diff --cc connectors/rocketmq-connect-redis/src/main/java/org/apache/rocketmq/connect/redis/parser/ZRemRangeByLexParser.java
index 0000000,cbdaf91..cbdaf91
mode 000000,100644..100644
--- a/connectors/rocketmq-connect-redis/src/main/java/org/apache/rocketmq/connect/redis/parser/ZRemRangeByLexParser.java
+++ b/connectors/rocketmq-connect-redis/src/main/java/org/apache/rocketmq/connect/redis/parser/ZRemRangeByLexParser.java
diff --cc connectors/rocketmq-connect-redis/src/main/java/org/apache/rocketmq/connect/redis/parser/ZRemRangeByRankParser.java
index 0000000,3827a41..3827a41
mode 000000,100644..100644
--- a/connectors/rocketmq-connect-redis/src/main/java/org/apache/rocketmq/connect/redis/parser/ZRemRangeByRankParser.java
+++ b/connectors/rocketmq-connect-redis/src/main/java/org/apache/rocketmq/connect/redis/parser/ZRemRangeByRankParser.java
diff --cc connectors/rocketmq-connect-redis/src/main/java/org/apache/rocketmq/connect/redis/parser/ZRemRangeByScoreParser.java
index 0000000,8693382..8693382
mode 000000,100644..100644
--- a/connectors/rocketmq-connect-redis/src/main/java/org/apache/rocketmq/connect/redis/parser/ZRemRangeByScoreParser.java
+++ b/connectors/rocketmq-connect-redis/src/main/java/org/apache/rocketmq/connect/redis/parser/ZRemRangeByScoreParser.java
diff --cc connectors/rocketmq-connect-redis/src/main/java/org/apache/rocketmq/connect/redis/parser/ZUnionStoreParser.java
index 0000000,04c0ef4..04c0ef4
mode 000000,100644..100644
--- a/connectors/rocketmq-connect-redis/src/main/java/org/apache/rocketmq/connect/redis/parser/ZUnionStoreParser.java
+++ b/connectors/rocketmq-connect-redis/src/main/java/org/apache/rocketmq/connect/redis/parser/ZUnionStoreParser.java
diff --cc connectors/rocketmq-connect-redis/src/main/java/org/apache/rocketmq/connect/redis/pojo/Geo.java
index 0000000,cf539db..cf539db
mode 000000,100644..100644
--- a/connectors/rocketmq-connect-redis/src/main/java/org/apache/rocketmq/connect/redis/pojo/Geo.java
+++ b/connectors/rocketmq-connect-redis/src/main/java/org/apache/rocketmq/connect/redis/pojo/Geo.java
diff --cc connectors/rocketmq-connect-redis/src/main/java/org/apache/rocketmq/connect/redis/pojo/KVEntry.java
index 0000000,ff8cb29..ff8cb29
mode 000000,100644..100644
--- a/connectors/rocketmq-connect-redis/src/main/java/org/apache/rocketmq/connect/redis/pojo/KVEntry.java
+++ b/connectors/rocketmq-connect-redis/src/main/java/org/apache/rocketmq/connect/redis/pojo/KVEntry.java
diff --cc connectors/rocketmq-connect-redis/src/main/java/org/apache/rocketmq/connect/redis/pojo/RedisEntry.java
index 0000000,5cf2d86..5cf2d86
mode 000000,100644..100644
--- a/connectors/rocketmq-connect-redis/src/main/java/org/apache/rocketmq/connect/redis/pojo/RedisEntry.java
+++ b/connectors/rocketmq-connect-redis/src/main/java/org/apache/rocketmq/connect/redis/pojo/RedisEntry.java
diff --cc connectors/rocketmq-connect-redis/src/main/java/org/apache/rocketmq/connect/redis/pojo/RedisEvent.java
index 0000000,585df47..585df47
mode 000000,100644..100644
--- a/connectors/rocketmq-connect-redis/src/main/java/org/apache/rocketmq/connect/redis/pojo/RedisEvent.java
+++ b/connectors/rocketmq-connect-redis/src/main/java/org/apache/rocketmq/connect/redis/pojo/RedisEvent.java
diff --cc connectors/rocketmq-connect-redis/src/main/java/org/apache/rocketmq/connect/redis/processor/DefaultRedisEventProcessor.java
index 0000000,cde4367..cde4367
mode 000000,100644..100644
--- a/connectors/rocketmq-connect-redis/src/main/java/org/apache/rocketmq/connect/redis/processor/DefaultRedisEventProcessor.java
+++ b/connectors/rocketmq-connect-redis/src/main/java/org/apache/rocketmq/connect/redis/processor/DefaultRedisEventProcessor.java
diff --cc connectors/rocketmq-connect-redis/src/main/java/org/apache/rocketmq/connect/redis/processor/RedisClosedListener.java
index 0000000,8a47fd8..8a47fd8
mode 000000,100644..100644
--- a/connectors/rocketmq-connect-redis/src/main/java/org/apache/rocketmq/connect/redis/processor/RedisClosedListener.java
+++ b/connectors/rocketmq-connect-redis/src/main/java/org/apache/rocketmq/connect/redis/processor/RedisClosedListener.java
diff --cc connectors/rocketmq-connect-redis/src/main/java/org/apache/rocketmq/connect/redis/processor/RedisEventListener.java
index 0000000,57d5aa8..57d5aa8
mode 000000,100644..100644
--- a/connectors/rocketmq-connect-redis/src/main/java/org/apache/rocketmq/connect/redis/processor/RedisEventListener.java
+++ b/connectors/rocketmq-connect-redis/src/main/java/org/apache/rocketmq/connect/redis/processor/RedisEventListener.java
diff --cc connectors/rocketmq-connect-redis/src/main/java/org/apache/rocketmq/connect/redis/processor/RedisEventProcessor.java
index 0000000,bdab382..bdab382
mode 000000,100644..100644
--- a/connectors/rocketmq-connect-redis/src/main/java/org/apache/rocketmq/connect/redis/processor/RedisEventProcessor.java
+++ b/connectors/rocketmq-connect-redis/src/main/java/org/apache/rocketmq/connect/redis/processor/RedisEventProcessor.java
diff --cc connectors/rocketmq-connect-redis/src/main/java/org/apache/rocketmq/connect/redis/processor/RedisEventProcessorCallback.java
index 0000000,c44f460..c44f460
mode 000000,100644..100644
--- a/connectors/rocketmq-connect-redis/src/main/java/org/apache/rocketmq/connect/redis/processor/RedisEventProcessorCallback.java
+++ b/connectors/rocketmq-connect-redis/src/main/java/org/apache/rocketmq/connect/redis/processor/RedisEventProcessorCallback.java
diff --cc connectors/rocketmq-connect-redis/src/main/java/org/apache/rocketmq/connect/redis/processor/RedisExceptionListener.java
index 0000000,bdbd139..bdbd139
mode 000000,100644..100644
--- a/connectors/rocketmq-connect-redis/src/main/java/org/apache/rocketmq/connect/redis/processor/RedisExceptionListener.java
+++ b/connectors/rocketmq-connect-redis/src/main/java/org/apache/rocketmq/connect/redis/processor/RedisExceptionListener.java
diff --cc connectors/rocketmq-connect-redis/src/main/java/org/apache/rocketmq/connect/redis/util/ParseStringUtils.java
index 0000000,b4714e5..b4714e5
mode 000000,100644..100644
--- a/connectors/rocketmq-connect-redis/src/main/java/org/apache/rocketmq/connect/redis/util/ParseStringUtils.java
+++ b/connectors/rocketmq-connect-redis/src/main/java/org/apache/rocketmq/connect/redis/util/ParseStringUtils.java
diff --cc connectors/rocketmq-connect-redis/src/main/java/org/apache/rocketmq/connect/redis/util/PropertyToObjectUtils.java
index 0000000,62f09ce..62f09ce
mode 000000,100644..100644
--- a/connectors/rocketmq-connect-redis/src/main/java/org/apache/rocketmq/connect/redis/util/PropertyToObjectUtils.java
+++ b/connectors/rocketmq-connect-redis/src/main/java/org/apache/rocketmq/connect/redis/util/PropertyToObjectUtils.java
diff --cc connectors/rocketmq-connect-redis/src/test/java/org/apache/rocketmq/redis/test/common/ConfigTest.java
index 0000000,e63f45f..e63f45f
mode 000000,100644..100644
--- a/connectors/rocketmq-connect-redis/src/test/java/org/apache/rocketmq/redis/test/common/ConfigTest.java
+++ b/connectors/rocketmq-connect-redis/src/test/java/org/apache/rocketmq/redis/test/common/ConfigTest.java
diff --cc connectors/rocketmq-connect-redis/src/test/java/org/apache/rocketmq/redis/test/common/OptionsTest.java
index 0000000,a7ac8ae..a7ac8ae
mode 000000,100644..100644
--- a/connectors/rocketmq-connect-redis/src/test/java/org/apache/rocketmq/redis/test/common/OptionsTest.java
+++ b/connectors/rocketmq-connect-redis/src/test/java/org/apache/rocketmq/redis/test/common/OptionsTest.java
diff --cc connectors/rocketmq-connect-redis/src/test/java/org/apache/rocketmq/redis/test/connector/RedisSourceConnectorTest.java
index 0000000,355351b..355351b
mode 000000,100644..100644
--- a/connectors/rocketmq-connect-redis/src/test/java/org/apache/rocketmq/redis/test/connector/RedisSourceConnectorTest.java
+++ b/connectors/rocketmq-connect-redis/src/test/java/org/apache/rocketmq/redis/test/connector/RedisSourceConnectorTest.java
diff --cc connectors/rocketmq-connect-redis/src/test/java/org/apache/rocketmq/redis/test/connector/RedisSourceTaskTest.java
index 0000000,4dd4397..4dd4397
mode 000000,100644..100644
--- a/connectors/rocketmq-connect-redis/src/test/java/org/apache/rocketmq/redis/test/connector/RedisSourceTaskTest.java
+++ b/connectors/rocketmq-connect-redis/src/test/java/org/apache/rocketmq/redis/test/connector/RedisSourceTaskTest.java
diff --cc connectors/rocketmq-connect-redis/src/test/java/org/apache/rocketmq/redis/test/converter/RedisEntryConverterTest.java
index 0000000,9b4d91c..9b4d91c
mode 000000,100644..100644
--- a/connectors/rocketmq-connect-redis/src/test/java/org/apache/rocketmq/redis/test/converter/RedisEntryConverterTest.java
+++ b/connectors/rocketmq-connect-redis/src/test/java/org/apache/rocketmq/redis/test/converter/RedisEntryConverterTest.java
diff --cc connectors/rocketmq-connect-redis/src/test/java/org/apache/rocketmq/redis/test/converter/RedisPositionConverterTest.java
index 0000000,03986d2..03986d2
mode 000000,100644..100644
--- a/connectors/rocketmq-connect-redis/src/test/java/org/apache/rocketmq/redis/test/converter/RedisPositionConverterTest.java
+++ b/connectors/rocketmq-connect-redis/src/test/java/org/apache/rocketmq/redis/test/converter/RedisPositionConverterTest.java
diff --cc connectors/rocketmq-connect-redis/src/test/java/org/apache/rocketmq/redis/test/handler/RedisEventHandlerTest.java
index 0000000,068187f..068187f
mode 000000,100644..100644
--- a/connectors/rocketmq-connect-redis/src/test/java/org/apache/rocketmq/redis/test/handler/RedisEventHandlerTest.java
+++ b/connectors/rocketmq-connect-redis/src/test/java/org/apache/rocketmq/redis/test/handler/RedisEventHandlerTest.java
diff --cc connectors/rocketmq-connect-redis/src/test/java/org/apache/rocketmq/redis/test/parser/ParserTest.java
index 0000000,b2b7960..b2b7960
mode 000000,100644..100644
--- a/connectors/rocketmq-connect-redis/src/test/java/org/apache/rocketmq/redis/test/parser/ParserTest.java
+++ b/connectors/rocketmq-connect-redis/src/test/java/org/apache/rocketmq/redis/test/parser/ParserTest.java
diff --cc connectors/rocketmq-connect-redis/src/test/java/org/apache/rocketmq/redis/test/pojo/GeoTest.java
index 0000000,c905140..c905140
mode 000000,100644..100644
--- a/connectors/rocketmq-connect-redis/src/test/java/org/apache/rocketmq/redis/test/pojo/GeoTest.java
+++ b/connectors/rocketmq-connect-redis/src/test/java/org/apache/rocketmq/redis/test/pojo/GeoTest.java
diff --cc connectors/rocketmq-connect-redis/src/test/java/org/apache/rocketmq/redis/test/pojo/KVEntryTest.java
index 0000000,65d8bcf..65d8bcf
mode 000000,100644..100644
--- a/connectors/rocketmq-connect-redis/src/test/java/org/apache/rocketmq/redis/test/pojo/KVEntryTest.java
+++ b/connectors/rocketmq-connect-redis/src/test/java/org/apache/rocketmq/redis/test/pojo/KVEntryTest.java
diff --cc connectors/rocketmq-connect-redis/src/test/java/org/apache/rocketmq/redis/test/pojo/RedisEventTest.java
index 0000000,a412e6d..a412e6d
mode 000000,100644..100644
--- a/connectors/rocketmq-connect-redis/src/test/java/org/apache/rocketmq/redis/test/pojo/RedisEventTest.java
+++ b/connectors/rocketmq-connect-redis/src/test/java/org/apache/rocketmq/redis/test/pojo/RedisEventTest.java
diff --cc connectors/rocketmq-connect-redis/src/test/java/org/apache/rocketmq/redis/test/processor/ListenerTest.java
index 0000000,6500eba..6500eba
mode 000000,100644..100644
--- a/connectors/rocketmq-connect-redis/src/test/java/org/apache/rocketmq/redis/test/processor/ListenerTest.java
+++ b/connectors/rocketmq-connect-redis/src/test/java/org/apache/rocketmq/redis/test/processor/ListenerTest.java
diff --cc connectors/rocketmq-connect-redis/src/test/java/org/apache/rocketmq/redis/test/processor/ProcessorTest.java
index 0000000,1410b2a..1410b2a
mode 000000,100644..100644
--- a/connectors/rocketmq-connect-redis/src/test/java/org/apache/rocketmq/redis/test/processor/ProcessorTest.java
+++ b/connectors/rocketmq-connect-redis/src/test/java/org/apache/rocketmq/redis/test/processor/ProcessorTest.java
diff --cc connectors/rocketmq-connect-redis/src/test/java/org/apache/rocketmq/redis/test/util/ParseStringUtilsTest.java
index 0000000,2a67959..2a67959
mode 000000,100644..100644
--- a/connectors/rocketmq-connect-redis/src/test/java/org/apache/rocketmq/redis/test/util/ParseStringUtilsTest.java
+++ b/connectors/rocketmq-connect-redis/src/test/java/org/apache/rocketmq/redis/test/util/ParseStringUtilsTest.java
diff --cc connectors/rocketmq-connect-redis/src/test/java/org/apache/rocketmq/redis/test/util/PropertyToObjectUtilsTest.java
index 0000000,ddcc59b..ddcc59b
mode 000000,100644..100644
--- a/connectors/rocketmq-connect-redis/src/test/java/org/apache/rocketmq/redis/test/util/PropertyToObjectUtilsTest.java
+++ b/connectors/rocketmq-connect-redis/src/test/java/org/apache/rocketmq/redis/test/util/PropertyToObjectUtilsTest.java
diff --cc connectors/rocketmq-connect-redis/style/copyright/Apache.xml
index 0000000,e3e3dec..e3e3dec
mode 000000,100644..100644
--- a/connectors/rocketmq-connect-redis/style/copyright/Apache.xml
+++ b/connectors/rocketmq-connect-redis/style/copyright/Apache.xml
diff --cc connectors/rocketmq-connect-redis/style/copyright/profiles_settings.xml
index 0000000,747c7e2..747c7e2
mode 000000,100644..100644
--- a/connectors/rocketmq-connect-redis/style/copyright/profiles_settings.xml
+++ b/connectors/rocketmq-connect-redis/style/copyright/profiles_settings.xml
diff --cc connectors/rocketmq-connect-redis/style/rmq_checkstyle.xml
index 0000000,2872eb7..2872eb7
mode 000000,100644..100644
--- a/connectors/rocketmq-connect-redis/style/rmq_checkstyle.xml
+++ b/connectors/rocketmq-connect-redis/style/rmq_checkstyle.xml
diff --cc connectors/rocketmq-connect-redis/style/rmq_codeStyle.xml
index 0000000,7c7ce54..7c7ce54
mode 000000,100644..100644
--- a/connectors/rocketmq-connect-redis/style/rmq_codeStyle.xml
+++ b/connectors/rocketmq-connect-redis/style/rmq_codeStyle.xml