Skip to content

Commit eb19b19

Browse files
W1y1rW1y1r
authored
Code example for logging in with username and password in the supplementary data subscription API (#599)
1 parent 2f58c9d commit eb19b19

8 files changed

Lines changed: 40 additions & 30 deletions

File tree

‎src/UserGuide/Master/Tree/API/Programming-Data-Subscription.md‎

Lines changed: 5 additions & 3 deletions
Original file line numberDiff line numberDiff line change
@@ -68,7 +68,7 @@ import org.apache.iotdb.session.subscription.model.Topic;
6868
public class DataConsumerExample {
6969

7070
public static void main(String[] args) throws IoTDBConnectionException, StatementExecutionException {
71-
try (SubscriptionSession session = new SubscriptionSession("127.0.0.1", 6667)) {
71+
try (SubscriptionSession session = new SubscriptionSession("127.0.0.1", 6667, "root", "root", 67108864)) {
7272
// 1. open session
7373
session.open();
7474

@@ -114,7 +114,8 @@ public class DataConsumerExample {
114114
Properties consumerConfig = new Properties();
115115
consumerConfig.put(ConsumerConstant.CONSUMER_ID_KEY, "c1");
116116
consumerConfig.put(ConsumerConstant.CONSUMER_GROUP_ID_KEY, "cg1");
117-
consumerConfig.put(ConsumerConstant.CONSUME_LISTENER_KEY, TopicConstant.FORMAT_SESSION_DATA_SETS_HANDLER_VALUE);
117+
consumerConfig.put(ConsumerConstant.USERNAME_KEY, "root");
118+
consumerConfig.put(ConsumerConstant.PASSWORD_KEY, "root");
118119
try (SubscriptionPullConsumer pullConsumer = new SubscriptionPullConsumer(consumerConfig)) {
119120
pullConsumer.open();
120121
pullConsumer.subscribe("topic_all");
@@ -161,7 +162,8 @@ public class DataConsumerExample {
161162
consumerConfig.put(ConsumerConstant.CONSUMER_ID_KEY, "c1");
162163
consumerConfig.put(ConsumerConstant.CONSUMER_GROUP_ID_KEY, "cg1");
163164
// 2. Specify the consumption type as the tsfile type
164-
consumerConfig.put(TopicConstant.FORMAT_KEY, TopicConstant.FORMAT_TS_FILE_HANDLER_VALUE);
165+
consumerConfig.put(ConsumerConstant.USERNAME_KEY, "root");
166+
consumerConfig.put(ConsumerConstant.PASSWORD_KEY, "root");
165167
consumerConfig.put(ConsumerConstant.FILE_SAVE_DIR_KEY, "/Users/iotdb/Downloads");
166168
try (SubscriptionPullConsumer pullConsumer = new SubscriptionPullConsumer(consumerConfig)) {
167169
pullConsumer.open();

‎src/UserGuide/V1.3.3/API/Programming-Data-Subscription.md‎

Lines changed: 5 additions & 4 deletions
Original file line numberDiff line numberDiff line change
@@ -68,7 +68,7 @@ import org.apache.iotdb.session.subscription.model.Topic;
6868
public class DataConsumerExample {
6969

7070
public static void main(String[] args) throws IoTDBConnectionException, StatementExecutionException {
71-
try (SubscriptionSession session = new SubscriptionSession("127.0.0.1", 6667)) {
71+
try (SubscriptionSession session = new SubscriptionSession("127.0.0.1", 6667, "root", "root", 67108864)) {
7272
// 1. open session
7373
session.open();
7474

@@ -114,7 +114,8 @@ public class DataConsumerExample {
114114
Properties consumerConfig = new Properties();
115115
consumerConfig.put(ConsumerConstant.CONSUMER_ID_KEY, "c1");
116116
consumerConfig.put(ConsumerConstant.CONSUMER_GROUP_ID_KEY, "cg1");
117-
consumerConfig.put(ConsumerConstant.CONSUME_LISTENER_KEY, TopicConstant.FORMAT_SESSION_DATA_SETS_HANDLER_VALUE);
117+
consumerConfig.put(ConsumerConstant.USERNAME_KEY, "root");
118+
consumerConfig.put(ConsumerConstant.PASSWORD_KEY, "root");
118119
try (SubscriptionPullConsumer pullConsumer = new SubscriptionPullConsumer(consumerConfig)) {
119120
pullConsumer.open();
120121
pullConsumer.subscribe("topic_all");
@@ -160,8 +161,8 @@ public class DataConsumerExample {
160161
Properties consumerConfig = new Properties();
161162
consumerConfig.put(ConsumerConstant.CONSUMER_ID_KEY, "c1");
162163
consumerConfig.put(ConsumerConstant.CONSUMER_GROUP_ID_KEY, "cg1");
163-
// 2. Specify the consumption type as the tsfile type
164-
consumerConfig.put(TopicConstant.FORMAT_KEY, TopicConstant.FORMAT_TS_FILE_HANDLER_VALUE);
164+
consumerConfig.put(ConsumerConstant.USERNAME_KEY, "root");
165+
consumerConfig.put(ConsumerConstant.PASSWORD_KEY, "root");
165166
consumerConfig.put(ConsumerConstant.FILE_SAVE_DIR_KEY, "/Users/iotdb/Downloads");
166167
try (SubscriptionPullConsumer pullConsumer = new SubscriptionPullConsumer(consumerConfig)) {
167168
pullConsumer.open();

‎src/UserGuide/dev-1.3/API/Programming-Data-Subscription.md‎

Lines changed: 5 additions & 4 deletions
Original file line numberDiff line numberDiff line change
@@ -68,7 +68,7 @@ import org.apache.iotdb.session.subscription.model.Topic;
6868
public class DataConsumerExample {
6969

7070
public static void main(String[] args) throws IoTDBConnectionException, StatementExecutionException {
71-
try (SubscriptionSession session = new SubscriptionSession("127.0.0.1", 6667)) {
71+
try (SubscriptionSession session = new SubscriptionSession("127.0.0.1", 6667, "root", "root", 67108864)) {
7272
// 1. open session
7373
session.open();
7474

@@ -114,7 +114,8 @@ public class DataConsumerExample {
114114
Properties consumerConfig = new Properties();
115115
consumerConfig.put(ConsumerConstant.CONSUMER_ID_KEY, "c1");
116116
consumerConfig.put(ConsumerConstant.CONSUMER_GROUP_ID_KEY, "cg1");
117-
consumerConfig.put(ConsumerConstant.CONSUME_LISTENER_KEY, TopicConstant.FORMAT_SESSION_DATA_SETS_HANDLER_VALUE);
117+
consumerConfig.put(ConsumerConstant.USERNAME_KEY, "root");
118+
consumerConfig.put(ConsumerConstant.PASSWORD_KEY, "root");
118119
try (SubscriptionPullConsumer pullConsumer = new SubscriptionPullConsumer(consumerConfig)) {
119120
pullConsumer.open();
120121
pullConsumer.subscribe("topic_all");
@@ -160,8 +161,8 @@ public class DataConsumerExample {
160161
Properties consumerConfig = new Properties();
161162
consumerConfig.put(ConsumerConstant.CONSUMER_ID_KEY, "c1");
162163
consumerConfig.put(ConsumerConstant.CONSUMER_GROUP_ID_KEY, "cg1");
163-
// 2. Specify the consumption type as the tsfile type
164-
consumerConfig.put(TopicConstant.FORMAT_KEY, TopicConstant.FORMAT_TS_FILE_HANDLER_VALUE);
164+
consumerConfig.put(ConsumerConstant.USERNAME_KEY, "root");
165+
consumerConfig.put(ConsumerConstant.PASSWORD_KEY, "root");
165166
consumerConfig.put(ConsumerConstant.FILE_SAVE_DIR_KEY, "/Users/iotdb/Downloads");
166167
try (SubscriptionPullConsumer pullConsumer = new SubscriptionPullConsumer(consumerConfig)) {
167168
pullConsumer.open();

‎src/UserGuide/latest/API/Programming-Data-Subscription.md‎

Lines changed: 5 additions & 3 deletions
Original file line numberDiff line numberDiff line change
@@ -68,7 +68,7 @@ import org.apache.iotdb.session.subscription.model.Topic;
6868
public class DataConsumerExample {
6969

7070
public static void main(String[] args) throws IoTDBConnectionException, StatementExecutionException {
71-
try (SubscriptionSession session = new SubscriptionSession("127.0.0.1", 6667)) {
71+
try (SubscriptionSession session = new SubscriptionSession("127.0.0.1", 6667, "root", "root", 67108864)) {
7272
// 1. open session
7373
session.open();
7474

@@ -114,7 +114,8 @@ public class DataConsumerExample {
114114
Properties consumerConfig = new Properties();
115115
consumerConfig.put(ConsumerConstant.CONSUMER_ID_KEY, "c1");
116116
consumerConfig.put(ConsumerConstant.CONSUMER_GROUP_ID_KEY, "cg1");
117-
consumerConfig.put(ConsumerConstant.CONSUME_LISTENER_KEY, TopicConstant.FORMAT_SESSION_DATA_SETS_HANDLER_VALUE);
117+
consumerConfig.put(ConsumerConstant.USERNAME_KEY, "root");
118+
consumerConfig.put(ConsumerConstant.PASSWORD_KEY, "root");
118119
try (SubscriptionPullConsumer pullConsumer = new SubscriptionPullConsumer(consumerConfig)) {
119120
pullConsumer.open();
120121
pullConsumer.subscribe("topic_all");
@@ -161,7 +162,8 @@ public class DataConsumerExample {
161162
consumerConfig.put(ConsumerConstant.CONSUMER_ID_KEY, "c1");
162163
consumerConfig.put(ConsumerConstant.CONSUMER_GROUP_ID_KEY, "cg1");
163164
// 2. Specify the consumption type as the tsfile type
164-
consumerConfig.put(TopicConstant.FORMAT_KEY, TopicConstant.FORMAT_TS_FILE_HANDLER_VALUE);
165+
consumerConfig.put(ConsumerConstant.USERNAME_KEY, "root");
166+
consumerConfig.put(ConsumerConstant.PASSWORD_KEY, "root");
165167
consumerConfig.put(ConsumerConstant.FILE_SAVE_DIR_KEY, "/Users/iotdb/Downloads");
166168
try (SubscriptionPullConsumer pullConsumer = new SubscriptionPullConsumer(consumerConfig)) {
167169
pullConsumer.open();

‎src/zh/UserGuide/Master/Tree/API/Programming-Data-Subscription.md‎

Lines changed: 5 additions & 4 deletions
Original file line numberDiff line numberDiff line change
@@ -68,7 +68,7 @@ import org.apache.iotdb.session.subscription.model.Topic;
6868
public class DataConsumerExample {
6969

7070
public static void main(String[] args) throws IoTDBConnectionException, StatementExecutionException {
71-
try (SubscriptionSession session = new SubscriptionSession("127.0.0.1", 6667)) {
71+
try (SubscriptionSession session = new SubscriptionSession("127.0.0.1", 6667, "root", "root", 67108864)) {
7272
// 1. open session
7373
session.open();
7474

@@ -114,7 +114,8 @@ public class DataConsumerExample {
114114
Properties consumerConfig = new Properties();
115115
consumerConfig.put(ConsumerConstant.CONSUMER_ID_KEY, "c1");
116116
consumerConfig.put(ConsumerConstant.CONSUMER_GROUP_ID_KEY, "cg1");
117-
consumerConfig.put(ConsumerConstant.CONSUME_LISTENER_KEY, TopicConstant.FORMAT_SESSION_DATA_SETS_HANDLER_VALUE);
117+
consumerConfig.put(ConsumerConstant.USERNAME_KEY, "root");
118+
consumerConfig.put(ConsumerConstant.PASSWORD_KEY, "root");
118119
try (SubscriptionPullConsumer pullConsumer = new SubscriptionPullConsumer(consumerConfig)) {
119120
pullConsumer.open();
120121
pullConsumer.subscribe("topic_all");
@@ -160,8 +161,8 @@ public class DataConsumerExample {
160161
Properties consumerConfig = new Properties();
161162
consumerConfig.put(ConsumerConstant.CONSUMER_ID_KEY, "c1");
162163
consumerConfig.put(ConsumerConstant.CONSUMER_GROUP_ID_KEY, "cg1");
163-
// 2. Specify the consumption type as the tsfile type
164-
consumerConfig.put(TopicConstant.FORMAT_KEY, TopicConstant.FORMAT_TS_FILE_HANDLER_VALUE);
164+
consumerConfig.put(ConsumerConstant.USERNAME_KEY, "root");
165+
consumerConfig.put(ConsumerConstant.PASSWORD_KEY, "root");
165166
consumerConfig.put(ConsumerConstant.FILE_SAVE_DIR_KEY, "/Users/iotdb/Downloads");
166167
try (SubscriptionPullConsumer pullConsumer = new SubscriptionPullConsumer(consumerConfig)) {
167168
pullConsumer.open();

‎src/zh/UserGuide/V1.3.3/API/Programming-Data-Subscription.md‎

Lines changed: 5 additions & 4 deletions
Original file line numberDiff line numberDiff line change
@@ -68,7 +68,7 @@ import org.apache.iotdb.session.subscription.model.Topic;
6868
public class DataConsumerExample {
6969

7070
public static void main(String[] args) throws IoTDBConnectionException, StatementExecutionException {
71-
try (SubscriptionSession session = new SubscriptionSession("127.0.0.1", 6667)) {
71+
try (SubscriptionSession session = new SubscriptionSession("127.0.0.1", 6667, "root", "root", 67108864)) {
7272
// 1. open session
7373
session.open();
7474

@@ -114,7 +114,8 @@ public class DataConsumerExample {
114114
Properties consumerConfig = new Properties();
115115
consumerConfig.put(ConsumerConstant.CONSUMER_ID_KEY, "c1");
116116
consumerConfig.put(ConsumerConstant.CONSUMER_GROUP_ID_KEY, "cg1");
117-
consumerConfig.put(ConsumerConstant.CONSUME_LISTENER_KEY, TopicConstant.FORMAT_SESSION_DATA_SETS_HANDLER_VALUE);
117+
consumerConfig.put(ConsumerConstant.USERNAME_KEY, "root");
118+
consumerConfig.put(ConsumerConstant.PASSWORD_KEY, "root");
118119
try (SubscriptionPullConsumer pullConsumer = new SubscriptionPullConsumer(consumerConfig)) {
119120
pullConsumer.open();
120121
pullConsumer.subscribe("topic_all");
@@ -160,8 +161,8 @@ public class DataConsumerExample {
160161
Properties consumerConfig = new Properties();
161162
consumerConfig.put(ConsumerConstant.CONSUMER_ID_KEY, "c1");
162163
consumerConfig.put(ConsumerConstant.CONSUMER_GROUP_ID_KEY, "cg1");
163-
// 2. Specify the consumption type as the tsfile type
164-
consumerConfig.put(TopicConstant.FORMAT_KEY, TopicConstant.FORMAT_TS_FILE_HANDLER_VALUE);
164+
consumerConfig.put(ConsumerConstant.USERNAME_KEY, "root");
165+
consumerConfig.put(ConsumerConstant.PASSWORD_KEY, "root");
165166
consumerConfig.put(ConsumerConstant.FILE_SAVE_DIR_KEY, "/Users/iotdb/Downloads");
166167
try (SubscriptionPullConsumer pullConsumer = new SubscriptionPullConsumer(consumerConfig)) {
167168
pullConsumer.open();

‎src/zh/UserGuide/dev-1.3/API/Programming-Data-Subscription.md‎

Lines changed: 5 additions & 4 deletions
Original file line numberDiff line numberDiff line change
@@ -68,7 +68,7 @@ import org.apache.iotdb.session.subscription.model.Topic;
6868
public class DataConsumerExample {
6969

7070
public static void main(String[] args) throws IoTDBConnectionException, StatementExecutionException {
71-
try (SubscriptionSession session = new SubscriptionSession("127.0.0.1", 6667)) {
71+
try (SubscriptionSession session = new SubscriptionSession("127.0.0.1", 6667, "root", "root", 67108864)) {
7272
// 1. open session
7373
session.open();
7474

@@ -114,7 +114,8 @@ public class DataConsumerExample {
114114
Properties consumerConfig = new Properties();
115115
consumerConfig.put(ConsumerConstant.CONSUMER_ID_KEY, "c1");
116116
consumerConfig.put(ConsumerConstant.CONSUMER_GROUP_ID_KEY, "cg1");
117-
consumerConfig.put(ConsumerConstant.CONSUME_LISTENER_KEY, TopicConstant.FORMAT_SESSION_DATA_SETS_HANDLER_VALUE);
117+
consumerConfig.put(ConsumerConstant.USERNAME_KEY, "root");
118+
consumerConfig.put(ConsumerConstant.PASSWORD_KEY, "root");
118119
try (SubscriptionPullConsumer pullConsumer = new SubscriptionPullConsumer(consumerConfig)) {
119120
pullConsumer.open();
120121
pullConsumer.subscribe("topic_all");
@@ -160,8 +161,8 @@ public class DataConsumerExample {
160161
Properties consumerConfig = new Properties();
161162
consumerConfig.put(ConsumerConstant.CONSUMER_ID_KEY, "c1");
162163
consumerConfig.put(ConsumerConstant.CONSUMER_GROUP_ID_KEY, "cg1");
163-
// 2. Specify the consumption type as the tsfile type
164-
consumerConfig.put(TopicConstant.FORMAT_KEY, TopicConstant.FORMAT_TS_FILE_HANDLER_VALUE);
164+
consumerConfig.put(ConsumerConstant.USERNAME_KEY, "root");
165+
consumerConfig.put(ConsumerConstant.PASSWORD_KEY, "root");
165166
consumerConfig.put(ConsumerConstant.FILE_SAVE_DIR_KEY, "/Users/iotdb/Downloads");
166167
try (SubscriptionPullConsumer pullConsumer = new SubscriptionPullConsumer(consumerConfig)) {
167168
pullConsumer.open();

‎src/zh/UserGuide/latest/API/Programming-Data-Subscription.md‎

Lines changed: 5 additions & 4 deletions
Original file line numberDiff line numberDiff line change
@@ -68,7 +68,7 @@ import org.apache.iotdb.session.subscription.model.Topic;
6868
public class DataConsumerExample {
6969

7070
public static void main(String[] args) throws IoTDBConnectionException, StatementExecutionException {
71-
try (SubscriptionSession session = new SubscriptionSession("127.0.0.1", 6667)) {
71+
try (SubscriptionSession session = new SubscriptionSession("127.0.0.1", 6667, "root", "root", 67108864)) {
7272
// 1. open session
7373
session.open();
7474

@@ -114,7 +114,8 @@ public class DataConsumerExample {
114114
Properties consumerConfig = new Properties();
115115
consumerConfig.put(ConsumerConstant.CONSUMER_ID_KEY, "c1");
116116
consumerConfig.put(ConsumerConstant.CONSUMER_GROUP_ID_KEY, "cg1");
117-
consumerConfig.put(ConsumerConstant.CONSUME_LISTENER_KEY, TopicConstant.FORMAT_SESSION_DATA_SETS_HANDLER_VALUE);
117+
consumerConfig.put(ConsumerConstant.USERNAME_KEY, "root");
118+
consumerConfig.put(ConsumerConstant.PASSWORD_KEY, "root");
118119
try (SubscriptionPullConsumer pullConsumer = new SubscriptionPullConsumer(consumerConfig)) {
119120
pullConsumer.open();
120121
pullConsumer.subscribe("topic_all");
@@ -160,8 +161,8 @@ public class DataConsumerExample {
160161
Properties consumerConfig = new Properties();
161162
consumerConfig.put(ConsumerConstant.CONSUMER_ID_KEY, "c1");
162163
consumerConfig.put(ConsumerConstant.CONSUMER_GROUP_ID_KEY, "cg1");
163-
// 2. Specify the consumption type as the tsfile type
164-
consumerConfig.put(TopicConstant.FORMAT_KEY, TopicConstant.FORMAT_TS_FILE_HANDLER_VALUE);
164+
consumerConfig.put(ConsumerConstant.USERNAME_KEY, "root");
165+
consumerConfig.put(ConsumerConstant.PASSWORD_KEY, "root");
165166
consumerConfig.put(ConsumerConstant.FILE_SAVE_DIR_KEY, "/Users/iotdb/Downloads");
166167
try (SubscriptionPullConsumer pullConsumer = new SubscriptionPullConsumer(consumerConfig)) {
167168
pullConsumer.open();

0 commit comments

Comments
 (0)