diff --git a/src/UserGuide/Master/Tree/API/Programming-Data-Subscription.md b/src/UserGuide/Master/Tree/API/Programming-Data-Subscription.md
index 4c0b6730b..9391c04a7 100644
--- a/src/UserGuide/Master/Tree/API/Programming-Data-Subscription.md
+++ b/src/UserGuide/Master/Tree/API/Programming-Data-Subscription.md
@@ -68,7 +68,7 @@ import org.apache.iotdb.session.subscription.model.Topic;
 public class DataConsumerExample {
 
     public static void main(String[] args) throws IoTDBConnectionException, StatementExecutionException {
-        try (SubscriptionSession session = new SubscriptionSession("127.0.0.1", 6667)) {
+        try (SubscriptionSession session = new SubscriptionSession("127.0.0.1", 6667, "root", "root", 67108864)) {
             // 1. open session
             session.open();
 
@@ -114,7 +114,8 @@ public class DataConsumerExample {
         Properties consumerConfig = new Properties();
         consumerConfig.put(ConsumerConstant.CONSUMER_ID_KEY, "c1");
         consumerConfig.put(ConsumerConstant.CONSUMER_GROUP_ID_KEY, "cg1");
-        consumerConfig.put(ConsumerConstant.CONSUME_LISTENER_KEY, TopicConstant.FORMAT_SESSION_DATA_SETS_HANDLER_VALUE);
+        consumerConfig.put(ConsumerConstant.USERNAME_KEY, "root");
+        consumerConfig.put(ConsumerConstant.PASSWORD_KEY, "root");
         try (SubscriptionPullConsumer pullConsumer = new SubscriptionPullConsumer(consumerConfig)) {
             pullConsumer.open();
             pullConsumer.subscribe("topic_all");
@@ -161,7 +162,8 @@ public class DataConsumerExample {
         consumerConfig.put(ConsumerConstant.CONSUMER_ID_KEY, "c1");
         consumerConfig.put(ConsumerConstant.CONSUMER_GROUP_ID_KEY, "cg1");
         // 2. Specify the consumption type as the tsfile type
-        consumerConfig.put(TopicConstant.FORMAT_KEY, TopicConstant.FORMAT_TS_FILE_HANDLER_VALUE);
+        consumerConfig.put(ConsumerConstant.USERNAME_KEY, "root");
+        consumerConfig.put(ConsumerConstant.PASSWORD_KEY, "root");
         consumerConfig.put(ConsumerConstant.FILE_SAVE_DIR_KEY, "/Users/iotdb/Downloads");
         try (SubscriptionPullConsumer pullConsumer = new SubscriptionPullConsumer(consumerConfig)) {
             pullConsumer.open();
diff --git a/src/UserGuide/V1.3.3/API/Programming-Data-Subscription.md b/src/UserGuide/V1.3.3/API/Programming-Data-Subscription.md
index 4c0b6730b..1c996e3c4 100644
--- a/src/UserGuide/V1.3.3/API/Programming-Data-Subscription.md
+++ b/src/UserGuide/V1.3.3/API/Programming-Data-Subscription.md
@@ -68,7 +68,7 @@ import org.apache.iotdb.session.subscription.model.Topic;
 public class DataConsumerExample {
 
     public static void main(String[] args) throws IoTDBConnectionException, StatementExecutionException {
-        try (SubscriptionSession session = new SubscriptionSession("127.0.0.1", 6667)) {
+        try (SubscriptionSession session = new SubscriptionSession("127.0.0.1", 6667, "root", "root", 67108864)) {
             // 1. open session
             session.open();
 
@@ -114,7 +114,8 @@ public class DataConsumerExample {
         Properties consumerConfig = new Properties();
         consumerConfig.put(ConsumerConstant.CONSUMER_ID_KEY, "c1");
         consumerConfig.put(ConsumerConstant.CONSUMER_GROUP_ID_KEY, "cg1");
-        consumerConfig.put(ConsumerConstant.CONSUME_LISTENER_KEY, TopicConstant.FORMAT_SESSION_DATA_SETS_HANDLER_VALUE);
+        consumerConfig.put(ConsumerConstant.USERNAME_KEY, "root");
+        consumerConfig.put(ConsumerConstant.PASSWORD_KEY, "root");
         try (SubscriptionPullConsumer pullConsumer = new SubscriptionPullConsumer(consumerConfig)) {
             pullConsumer.open();
             pullConsumer.subscribe("topic_all");
@@ -160,8 +161,8 @@ public class DataConsumerExample {
         Properties consumerConfig = new Properties();
         consumerConfig.put(ConsumerConstant.CONSUMER_ID_KEY, "c1");
         consumerConfig.put(ConsumerConstant.CONSUMER_GROUP_ID_KEY, "cg1");
-        // 2. Specify the consumption type as the tsfile type
-        consumerConfig.put(TopicConstant.FORMAT_KEY, TopicConstant.FORMAT_TS_FILE_HANDLER_VALUE);
+        consumerConfig.put(ConsumerConstant.USERNAME_KEY, "root");
+        consumerConfig.put(ConsumerConstant.PASSWORD_KEY, "root");
         consumerConfig.put(ConsumerConstant.FILE_SAVE_DIR_KEY, "/Users/iotdb/Downloads");
         try (SubscriptionPullConsumer pullConsumer = new SubscriptionPullConsumer(consumerConfig)) {
             pullConsumer.open();
diff --git a/src/UserGuide/dev-1.3/API/Programming-Data-Subscription.md b/src/UserGuide/dev-1.3/API/Programming-Data-Subscription.md
index 4c0b6730b..1c996e3c4 100644
--- a/src/UserGuide/dev-1.3/API/Programming-Data-Subscription.md
+++ b/src/UserGuide/dev-1.3/API/Programming-Data-Subscription.md
@@ -68,7 +68,7 @@ import org.apache.iotdb.session.subscription.model.Topic;
 public class DataConsumerExample {
 
     public static void main(String[] args) throws IoTDBConnectionException, StatementExecutionException {
-        try (SubscriptionSession session = new SubscriptionSession("127.0.0.1", 6667)) {
+        try (SubscriptionSession session = new SubscriptionSession("127.0.0.1", 6667, "root", "root", 67108864)) {
             // 1. open session
             session.open();
 
@@ -114,7 +114,8 @@ public class DataConsumerExample {
         Properties consumerConfig = new Properties();
         consumerConfig.put(ConsumerConstant.CONSUMER_ID_KEY, "c1");
         consumerConfig.put(ConsumerConstant.CONSUMER_GROUP_ID_KEY, "cg1");
-        consumerConfig.put(ConsumerConstant.CONSUME_LISTENER_KEY, TopicConstant.FORMAT_SESSION_DATA_SETS_HANDLER_VALUE);
+        consumerConfig.put(ConsumerConstant.USERNAME_KEY, "root");
+        consumerConfig.put(ConsumerConstant.PASSWORD_KEY, "root");
         try (SubscriptionPullConsumer pullConsumer = new SubscriptionPullConsumer(consumerConfig)) {
             pullConsumer.open();
             pullConsumer.subscribe("topic_all");
@@ -160,8 +161,8 @@ public class DataConsumerExample {
         Properties consumerConfig = new Properties();
         consumerConfig.put(ConsumerConstant.CONSUMER_ID_KEY, "c1");
         consumerConfig.put(ConsumerConstant.CONSUMER_GROUP_ID_KEY, "cg1");
-        // 2. Specify the consumption type as the tsfile type
-        consumerConfig.put(TopicConstant.FORMAT_KEY, TopicConstant.FORMAT_TS_FILE_HANDLER_VALUE);
+        consumerConfig.put(ConsumerConstant.USERNAME_KEY, "root");
+        consumerConfig.put(ConsumerConstant.PASSWORD_KEY, "root");
         consumerConfig.put(ConsumerConstant.FILE_SAVE_DIR_KEY, "/Users/iotdb/Downloads");
         try (SubscriptionPullConsumer pullConsumer = new SubscriptionPullConsumer(consumerConfig)) {
             pullConsumer.open();
diff --git a/src/UserGuide/latest/API/Programming-Data-Subscription.md b/src/UserGuide/latest/API/Programming-Data-Subscription.md
index 4c0b6730b..9391c04a7 100644
--- a/src/UserGuide/latest/API/Programming-Data-Subscription.md
+++ b/src/UserGuide/latest/API/Programming-Data-Subscription.md
@@ -68,7 +68,7 @@ import org.apache.iotdb.session.subscription.model.Topic;
 public class DataConsumerExample {
 
     public static void main(String[] args) throws IoTDBConnectionException, StatementExecutionException {
-        try (SubscriptionSession session = new SubscriptionSession("127.0.0.1", 6667)) {
+        try (SubscriptionSession session = new SubscriptionSession("127.0.0.1", 6667, "root", "root", 67108864)) {
             // 1. open session
             session.open();
 
@@ -114,7 +114,8 @@ public class DataConsumerExample {
         Properties consumerConfig = new Properties();
         consumerConfig.put(ConsumerConstant.CONSUMER_ID_KEY, "c1");
         consumerConfig.put(ConsumerConstant.CONSUMER_GROUP_ID_KEY, "cg1");
-        consumerConfig.put(ConsumerConstant.CONSUME_LISTENER_KEY, TopicConstant.FORMAT_SESSION_DATA_SETS_HANDLER_VALUE);
+        consumerConfig.put(ConsumerConstant.USERNAME_KEY, "root");
+        consumerConfig.put(ConsumerConstant.PASSWORD_KEY, "root");
         try (SubscriptionPullConsumer pullConsumer = new SubscriptionPullConsumer(consumerConfig)) {
             pullConsumer.open();
             pullConsumer.subscribe("topic_all");
@@ -161,7 +162,8 @@ public class DataConsumerExample {
         consumerConfig.put(ConsumerConstant.CONSUMER_ID_KEY, "c1");
         consumerConfig.put(ConsumerConstant.CONSUMER_GROUP_ID_KEY, "cg1");
         // 2. Specify the consumption type as the tsfile type
-        consumerConfig.put(TopicConstant.FORMAT_KEY, TopicConstant.FORMAT_TS_FILE_HANDLER_VALUE);
+        consumerConfig.put(ConsumerConstant.USERNAME_KEY, "root");
+        consumerConfig.put(ConsumerConstant.PASSWORD_KEY, "root");
         consumerConfig.put(ConsumerConstant.FILE_SAVE_DIR_KEY, "/Users/iotdb/Downloads");
         try (SubscriptionPullConsumer pullConsumer = new SubscriptionPullConsumer(consumerConfig)) {
             pullConsumer.open();
diff --git a/src/zh/UserGuide/Master/Tree/API/Programming-Data-Subscription.md b/src/zh/UserGuide/Master/Tree/API/Programming-Data-Subscription.md
index fe8896cd4..2e387bd8a 100644
--- a/src/zh/UserGuide/Master/Tree/API/Programming-Data-Subscription.md
+++ b/src/zh/UserGuide/Master/Tree/API/Programming-Data-Subscription.md
@@ -68,7 +68,7 @@ import org.apache.iotdb.session.subscription.model.Topic;
 public class DataConsumerExample {
 
     public static void main(String[] args) throws IoTDBConnectionException, StatementExecutionException {
-        try (SubscriptionSession session = new SubscriptionSession("127.0.0.1", 6667)) {
+        try (SubscriptionSession session = new SubscriptionSession("127.0.0.1", 6667, "root", "root", 67108864)) {
             // 1. open session
             session.open();
 
@@ -114,7 +114,8 @@ public class DataConsumerExample {
         Properties consumerConfig = new Properties();
         consumerConfig.put(ConsumerConstant.CONSUMER_ID_KEY, "c1");
         consumerConfig.put(ConsumerConstant.CONSUMER_GROUP_ID_KEY, "cg1");
-        consumerConfig.put(ConsumerConstant.CONSUME_LISTENER_KEY, TopicConstant.FORMAT_SESSION_DATA_SETS_HANDLER_VALUE);
+        consumerConfig.put(ConsumerConstant.USERNAME_KEY, "root");
+        consumerConfig.put(ConsumerConstant.PASSWORD_KEY, "root");
         try (SubscriptionPullConsumer pullConsumer = new SubscriptionPullConsumer(consumerConfig)) {
             pullConsumer.open();
             pullConsumer.subscribe("topic_all");
@@ -160,8 +161,8 @@ public class DataConsumerExample {
         Properties consumerConfig = new Properties();
         consumerConfig.put(ConsumerConstant.CONSUMER_ID_KEY, "c1");
         consumerConfig.put(ConsumerConstant.CONSUMER_GROUP_ID_KEY, "cg1");
-        // 2. Specify the consumption type as the tsfile type
-        consumerConfig.put(TopicConstant.FORMAT_KEY, TopicConstant.FORMAT_TS_FILE_HANDLER_VALUE);
+        consumerConfig.put(ConsumerConstant.USERNAME_KEY, "root");
+        consumerConfig.put(ConsumerConstant.PASSWORD_KEY, "root");
         consumerConfig.put(ConsumerConstant.FILE_SAVE_DIR_KEY, "/Users/iotdb/Downloads");
         try (SubscriptionPullConsumer pullConsumer = new SubscriptionPullConsumer(consumerConfig)) {
             pullConsumer.open();
diff --git a/src/zh/UserGuide/V1.3.3/API/Programming-Data-Subscription.md b/src/zh/UserGuide/V1.3.3/API/Programming-Data-Subscription.md
index fe8896cd4..2e387bd8a 100644
--- a/src/zh/UserGuide/V1.3.3/API/Programming-Data-Subscription.md
+++ b/src/zh/UserGuide/V1.3.3/API/Programming-Data-Subscription.md
@@ -68,7 +68,7 @@ import org.apache.iotdb.session.subscription.model.Topic;
 public class DataConsumerExample {
 
     public static void main(String[] args) throws IoTDBConnectionException, StatementExecutionException {
-        try (SubscriptionSession session = new SubscriptionSession("127.0.0.1", 6667)) {
+        try (SubscriptionSession session = new SubscriptionSession("127.0.0.1", 6667, "root", "root", 67108864)) {
             // 1. open session
             session.open();
 
@@ -114,7 +114,8 @@ public class DataConsumerExample {
         Properties consumerConfig = new Properties();
         consumerConfig.put(ConsumerConstant.CONSUMER_ID_KEY, "c1");
         consumerConfig.put(ConsumerConstant.CONSUMER_GROUP_ID_KEY, "cg1");
-        consumerConfig.put(ConsumerConstant.CONSUME_LISTENER_KEY, TopicConstant.FORMAT_SESSION_DATA_SETS_HANDLER_VALUE);
+        consumerConfig.put(ConsumerConstant.USERNAME_KEY, "root");
+        consumerConfig.put(ConsumerConstant.PASSWORD_KEY, "root");
         try (SubscriptionPullConsumer pullConsumer = new SubscriptionPullConsumer(consumerConfig)) {
             pullConsumer.open();
             pullConsumer.subscribe("topic_all");
@@ -160,8 +161,8 @@ public class DataConsumerExample {
         Properties consumerConfig = new Properties();
         consumerConfig.put(ConsumerConstant.CONSUMER_ID_KEY, "c1");
         consumerConfig.put(ConsumerConstant.CONSUMER_GROUP_ID_KEY, "cg1");
-        // 2. Specify the consumption type as the tsfile type
-        consumerConfig.put(TopicConstant.FORMAT_KEY, TopicConstant.FORMAT_TS_FILE_HANDLER_VALUE);
+        consumerConfig.put(ConsumerConstant.USERNAME_KEY, "root");
+        consumerConfig.put(ConsumerConstant.PASSWORD_KEY, "root");
         consumerConfig.put(ConsumerConstant.FILE_SAVE_DIR_KEY, "/Users/iotdb/Downloads");
         try (SubscriptionPullConsumer pullConsumer = new SubscriptionPullConsumer(consumerConfig)) {
             pullConsumer.open();
diff --git a/src/zh/UserGuide/dev-1.3/API/Programming-Data-Subscription.md b/src/zh/UserGuide/dev-1.3/API/Programming-Data-Subscription.md
index fe8896cd4..2e387bd8a 100644
--- a/src/zh/UserGuide/dev-1.3/API/Programming-Data-Subscription.md
+++ b/src/zh/UserGuide/dev-1.3/API/Programming-Data-Subscription.md
@@ -68,7 +68,7 @@ import org.apache.iotdb.session.subscription.model.Topic;
 public class DataConsumerExample {
 
     public static void main(String[] args) throws IoTDBConnectionException, StatementExecutionException {
-        try (SubscriptionSession session = new SubscriptionSession("127.0.0.1", 6667)) {
+        try (SubscriptionSession session = new SubscriptionSession("127.0.0.1", 6667, "root", "root", 67108864)) {
             // 1. open session
             session.open();
 
@@ -114,7 +114,8 @@ public class DataConsumerExample {
         Properties consumerConfig = new Properties();
         consumerConfig.put(ConsumerConstant.CONSUMER_ID_KEY, "c1");
         consumerConfig.put(ConsumerConstant.CONSUMER_GROUP_ID_KEY, "cg1");
-        consumerConfig.put(ConsumerConstant.CONSUME_LISTENER_KEY, TopicConstant.FORMAT_SESSION_DATA_SETS_HANDLER_VALUE);
+        consumerConfig.put(ConsumerConstant.USERNAME_KEY, "root");
+        consumerConfig.put(ConsumerConstant.PASSWORD_KEY, "root");
         try (SubscriptionPullConsumer pullConsumer = new SubscriptionPullConsumer(consumerConfig)) {
             pullConsumer.open();
             pullConsumer.subscribe("topic_all");
@@ -160,8 +161,8 @@ public class DataConsumerExample {
         Properties consumerConfig = new Properties();
         consumerConfig.put(ConsumerConstant.CONSUMER_ID_KEY, "c1");
         consumerConfig.put(ConsumerConstant.CONSUMER_GROUP_ID_KEY, "cg1");
-        // 2. Specify the consumption type as the tsfile type
-        consumerConfig.put(TopicConstant.FORMAT_KEY, TopicConstant.FORMAT_TS_FILE_HANDLER_VALUE);
+        consumerConfig.put(ConsumerConstant.USERNAME_KEY, "root");
+        consumerConfig.put(ConsumerConstant.PASSWORD_KEY, "root");
         consumerConfig.put(ConsumerConstant.FILE_SAVE_DIR_KEY, "/Users/iotdb/Downloads");
         try (SubscriptionPullConsumer pullConsumer = new SubscriptionPullConsumer(consumerConfig)) {
             pullConsumer.open();
diff --git a/src/zh/UserGuide/latest/API/Programming-Data-Subscription.md b/src/zh/UserGuide/latest/API/Programming-Data-Subscription.md
index fe8896cd4..2e387bd8a 100644
--- a/src/zh/UserGuide/latest/API/Programming-Data-Subscription.md
+++ b/src/zh/UserGuide/latest/API/Programming-Data-Subscription.md
@@ -68,7 +68,7 @@ import org.apache.iotdb.session.subscription.model.Topic;
 public class DataConsumerExample {
 
     public static void main(String[] args) throws IoTDBConnectionException, StatementExecutionException {
-        try (SubscriptionSession session = new SubscriptionSession("127.0.0.1", 6667)) {
+        try (SubscriptionSession session = new SubscriptionSession("127.0.0.1", 6667, "root", "root", 67108864)) {
             // 1. open session
             session.open();
 
@@ -114,7 +114,8 @@ public class DataConsumerExample {
         Properties consumerConfig = new Properties();
         consumerConfig.put(ConsumerConstant.CONSUMER_ID_KEY, "c1");
         consumerConfig.put(ConsumerConstant.CONSUMER_GROUP_ID_KEY, "cg1");
-        consumerConfig.put(ConsumerConstant.CONSUME_LISTENER_KEY, TopicConstant.FORMAT_SESSION_DATA_SETS_HANDLER_VALUE);
+        consumerConfig.put(ConsumerConstant.USERNAME_KEY, "root");
+        consumerConfig.put(ConsumerConstant.PASSWORD_KEY, "root");
         try (SubscriptionPullConsumer pullConsumer = new SubscriptionPullConsumer(consumerConfig)) {
             pullConsumer.open();
             pullConsumer.subscribe("topic_all");
@@ -160,8 +161,8 @@ public class DataConsumerExample {
         Properties consumerConfig = new Properties();
         consumerConfig.put(ConsumerConstant.CONSUMER_ID_KEY, "c1");
         consumerConfig.put(ConsumerConstant.CONSUMER_GROUP_ID_KEY, "cg1");
-        // 2. Specify the consumption type as the tsfile type
-        consumerConfig.put(TopicConstant.FORMAT_KEY, TopicConstant.FORMAT_TS_FILE_HANDLER_VALUE);
+        consumerConfig.put(ConsumerConstant.USERNAME_KEY, "root");
+        consumerConfig.put(ConsumerConstant.PASSWORD_KEY, "root");
         consumerConfig.put(ConsumerConstant.FILE_SAVE_DIR_KEY, "/Users/iotdb/Downloads");
         try (SubscriptionPullConsumer pullConsumer = new SubscriptionPullConsumer(consumerConfig)) {
             pullConsumer.open();