diff --git a/chunjun-connectors/chunjun-connector-redis/src/main/java/com/dtstack/chunjun/connector/redis/table/RedisDynamicTableFactory.java b/chunjun-connectors/chunjun-connector-redis/src/main/java/com/dtstack/chunjun/connector/redis/table/RedisDynamicTableFactory.java
index cdb5fa57ce..7021171fc4 100644
--- a/chunjun-connectors/chunjun-connector-redis/src/main/java/com/dtstack/chunjun/connector/redis/table/RedisDynamicTableFactory.java
+++ b/chunjun-connectors/chunjun-connector-redis/src/main/java/com/dtstack/chunjun/connector/redis/table/RedisDynamicTableFactory.java
@@ -46,7 +46,6 @@
 
 import static com.dtstack.chunjun.connector.redis.options.RedisOptions.DATABASE;
 import static com.dtstack.chunjun.connector.redis.options.RedisOptions.KEYEXPIREDTIME;
-import static com.dtstack.chunjun.connector.redis.options.RedisOptions.KEY_PREFIX;
 import static com.dtstack.chunjun.connector.redis.options.RedisOptions.MASTERNAME;
 import static com.dtstack.chunjun.connector.redis.options.RedisOptions.MAXIDLE;
 import static com.dtstack.chunjun.connector.redis.options.RedisOptions.MAXTOTAL;
@@ -123,6 +122,7 @@ public String factoryIdentifier() {
     public Set<ConfigOption<?>> requiredOptions() {
         Set<ConfigOption<?>> requiredOptions = new HashSet<>();
         requiredOptions.add(URL);
+        requiredOptions.add(TABLENAME);
         requiredOptions.add(REDIS_DATA_TYPE);
         requiredOptions.add(REDIS_DATA_MODE);
         return requiredOptions;
@@ -131,8 +131,6 @@ public Set<ConfigOption<?>> requiredOptions() {
     @Override
     public Set<ConfigOption<?>> optionalOptions() {
         Set<ConfigOption<?>> optionalOptions = new HashSet<>();
-        optionalOptions.add(KEY_PREFIX);
-        optionalOptions.add(TABLENAME);
         optionalOptions.add(PASSWORD);
         optionalOptions.add(REDISTYPE);
         optionalOptions.add(MASTERNAME);
@@ -172,7 +170,7 @@ private RedisConf getRedisConf(ReadableConfig config, TableSchema schema) {
         redisConf.setExpireTime(config.get(KEYEXPIREDTIME));
         redisConf.setType(RedisDataType.getDataType(config.get(REDIS_DATA_TYPE)));
         redisConf.setMode(RedisDataMode.getDataMode(config.get(REDIS_DATA_MODE)));
-        redisConf.setKeyPrefix(config.get(KEY_PREFIX));
+        redisConf.setKeyPrefix(config.get(TABLENAME));
         List<String> keyFields = schema.getPrimaryKey().map(pk -> pk.getColumns()).orElse(null);
         redisConf.setUpdateKey(keyFields);
         return redisConf;
diff --git a/chunjun-examples/sql/redis/redis_stream.sql b/chunjun-examples/sql/redis/redis_stream.sql
index fa6f5f41b5..1efae79ce8 100644
--- a/chunjun-examples/sql/redis/redis_stream.sql
+++ b/chunjun-examples/sql/redis/redis_stream.sql
@@ -7,10 +7,10 @@ CREATE TABLE source
     status       STRING
 ) WITH (
       'connector' = 'redis-x',
-      'url'= 'localhost:6379',
+      'url'= 'hadoop101:6379',
       'database' = '1',
       'password' = '123456',
-      'keyPrefix' = 'run_power*',
+      'table-name' = 'run_power*',
       'type' = 'hash',
       'mode' = 'hget'
       );
diff --git "a/docs_zh/ChunJun\350\277\236\346\216\245\345\231\250/redis/redis_source.md" "b/docs_zh/ChunJun\350\277\236\346\216\245\345\231\250/redis/redis_source.md"
index 2bade8ca5e..5fa82932ec 100644
--- "a/docs_zh/ChunJun\350\277\236\346\216\245\345\231\250/redis/redis_source.md"
+++ "b/docs_zh/ChunJun\350\277\236\346\216\245\345\231\250/redis/redis_source.md"
@@ -26,7 +26,7 @@ redis2.9以上
   - 描述：要写入Redis数据库
   - 必选：否
   - 默认值：0
-- **keyPrefix**
+- **table-name**
   - 描述：需要匹配的key前缀
   - 必选：是
   - 默认值：无