更新redis配置

seatunnel-datasource/seatunnel-datasource-plugins/datasource-redis/src/main/java/org/apache/seatunnel/datasource/plugin/redis/RedisAConfiguration.java

@@ -42,9 +42,9 @@ public class RedisAConfiguration {
             throw new IllegalArgumentException(
                     "redis datasource auth is null, please check your config");
         }
-        if (!redisOption.containsKey(RedisOptionRule.KEY.key())) {
+        if (!redisOption.containsKey(RedisOptionRule.KEY_PATTERN.key())) {
             throw new IllegalArgumentException(
-                    "redis datasource key is null, please check your config");
+                    "redis datasource keys is null, please check your config");
         }
         if (!redisOption.containsKey(RedisOptionRule.DATA_TYPE.key())) {
             throw new IllegalArgumentException(
@@ -55,7 +55,7 @@ public class RedisAConfiguration {
         redisConfiguration.setPort(Integer.valueOf(redisOption.get(RedisOptionRule.PORT.key())));
         redisConfiguration.setMode(redisOption.get(RedisOptionRule.MODE.key()));
         redisConfiguration.setAuth(redisOption.get(RedisOptionRule.AUTH.key()));
-        redisConfiguration.setKey(redisOption.get(RedisOptionRule.KEY.key()));
+        redisConfiguration.setKeys(redisOption.get(RedisOptionRule.KEY_PATTERN.key()));
         redisConfiguration.setData_type(redisOption.get(RedisOptionRule.DATA_TYPE.key()));
 
         return redisConfiguration;

seatunnel-datasource/seatunnel-datasource-plugins/datasource-redis/src/main/java/org/apache/seatunnel/datasource/plugin/redis/RedisConfiguration.java

@@ -5,7 +5,7 @@ public class RedisConfiguration {
     private Integer port;
     private String user;
     private String auth;
-    private String key;
+    private String keys;
     private String data_type;
     private String mode;
 
@@ -16,14 +16,14 @@ public class RedisConfiguration {
             Integer port,
             String user,
             String auth,
-            String key,
+            String keys,
             String data_type,
             String mode) {
         this.host = host;
         this.port = port;
         this.user = user;
         this.auth = auth;
-        this.key = key;
+        this.keys = keys;
         this.data_type = data_type;
         this.mode = mode;
     }
@@ -42,8 +42,8 @@ public class RedisConfiguration {
                 + ", auth='"
                 + auth
                 + '\''
-                + ", key='"
-                + key
+                + ", keys='"
+                + keys
                 + '\''
                 + ", data_type='"
                 + data_type
@@ -86,12 +86,12 @@ public class RedisConfiguration {
         this.auth = auth;
     }
 
-    public String getKey() {
-        return key;
+    public String getKeys() {
+        return keys;
     }
 
-    public void setKey(String key) {
-        this.key = key;
+    public void setKeys(String keys) {
+        this.keys = keys;
     }
 
     public String getData_type() {

seatunnel-datasource/seatunnel-datasource-plugins/datasource-redis/src/main/java/org/apache/seatunnel/datasource/plugin/redis/RedisOptionRule.java

@@ -63,12 +63,6 @@ public class RedisOptionRule {
                     .withDescription(
                             "keys pattern, redis source connector support fuzzy key matching, user needs to ensure that the matched keys are the same type");
 
-    public static final Option<String> KEY =
-            Options.key("key")
-                    .stringType()
-                    .noDefaultValue()
-                    .withDescription("The value of key you want to write to redis.");
-
     public static final Option<String> DATA_TYPE =
             Options.key("data_type")
                     .stringType()
@@ -105,8 +99,8 @@ public class RedisOptionRule {
 
     public static OptionRule optionRule() {
         return OptionRule.builder()
-                .required(HOST, PORT, KEY, DATA_TYPE)
-                .optional(USER, AUTH, MODE, FORMAT, HASH_KEY_PARSE_MODE, KEY_PATTERN)
+                .required(HOST, PORT, KEY_PATTERN, DATA_TYPE)
+                .optional(USER, AUTH, MODE, FORMAT, HASH_KEY_PARSE_MODE)
                 .build();
     }