This is an automated email from the ASF dual-hosted git repository.
qiaojialin pushed a commit to branch main
in repository https://gitbox.apache.org/repos/asf/iotdb-docs.git
The following commit(s) were added to refs/heads/main by this push:
new eb19b190 Code example for logging in with username and password in the
supplementary data subscription API (#599)
eb19b190 is described below
commit eb19b190c63bef968afc70e9d0adb3c4c8c03cc0
Author: W1y1r <[email protected]>
AuthorDate: Tue Feb 25 17:06:18 2025 +0800
Code example for logging in with username and password in the supplementary
data subscription API (#599)
---
src/UserGuide/Master/Tree/API/Programming-Data-Subscription.md | 8 +++++---
src/UserGuide/V1.3.3/API/Programming-Data-Subscription.md | 9 +++++----
src/UserGuide/dev-1.3/API/Programming-Data-Subscription.md | 9 +++++----
src/UserGuide/latest/API/Programming-Data-Subscription.md | 8 +++++---
.../UserGuide/Master/Tree/API/Programming-Data-Subscription.md | 9 +++++----
src/zh/UserGuide/V1.3.3/API/Programming-Data-Subscription.md | 9 +++++----
src/zh/UserGuide/dev-1.3/API/Programming-Data-Subscription.md | 9 +++++----
src/zh/UserGuide/latest/API/Programming-Data-Subscription.md | 9 +++++----
8 files changed, 40 insertions(+), 30 deletions(-)
diff --git a/src/UserGuide/Master/Tree/API/Programming-Data-Subscription.md
b/src/UserGuide/Master/Tree/API/Programming-Data-Subscription.md
index 4c0b6730..9391c04a 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 4c0b6730..1c996e3c 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 4c0b6730..1c996e3c 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 4c0b6730..9391c04a 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 fe8896cd..2e387bd8 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 fe8896cd..2e387bd8 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 fe8896cd..2e387bd8 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 fe8896cd..2e387bd8 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();
