You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@doris.apache.org by zy...@apache.org on 2023/06/20 15:20:09 UTC
[doris] branch master updated: [typo](doc) To access a Kafka cluster with PLAIN authentication enabled (#21019)
This is an automated email from the ASF dual-hosted git repository.
zykkk pushed a commit to branch master
in repository https://gitbox.apache.org/repos/asf/doris.git
The following commit(s) were added to refs/heads/master by this push:
new d7cc05502a [typo](doc) To access a Kafka cluster with PLAIN authentication enabled (#21019)
d7cc05502a is described below
commit d7cc05502acc899337dd3524e1294a70ea9ee9fe
Author: yuanyuan8983 <99...@users.noreply.github.com>
AuthorDate: Tue Jun 20 23:19:59 2023 +0800
[typo](doc) To access a Kafka cluster with PLAIN authentication enabled (#21019)
---
.../import/import-way/routine-load-manual.md | 28 ++++++++++++++++++++++
.../import/import-way/routine-load-manual.md | 28 ++++++++++++++++++++++
2 files changed, 56 insertions(+)
diff --git a/docs/en/docs/data-operate/import/import-way/routine-load-manual.md b/docs/en/docs/data-operate/import/import-way/routine-load-manual.md
index 7d304fae80..85ad44a74e 100644
--- a/docs/en/docs/data-operate/import/import-way/routine-load-manual.md
+++ b/docs/en/docs/data-operate/import/import-way/routine-load-manual.md
@@ -410,6 +410,34 @@ FROM KAFKA
>
>
+**Access the PLAIN certified Kafka cluster**
+
+To access a Kafka cluster with PLAIN authentication enabled, you need to add the following configuration：
+
+ - property.security.protocol=SASL_PLAINTEXT : Use SASL plaintext
+ - property.sasl.mechanism=PLAIN : Set the SASL authentication mode to PLAIN
+ - property.sasl.username=admin : Set the SASL user name
+ - property.sasl.password=admin : Set the SASL password
+
+1. Create a routine import job
+
+ ```sql
+ CREATE ROUTINE LOAD db1.job1 on tbl1
+ PROPERTIES (
+ "desired_concurrent_number"="1",
+ )
+ FROM KAFKA
+ (
+ "kafka_broker_list" = "broker1:9092,broker2:9092",
+ "kafka_topic" = "my_topic",
+ "property.security.protocol"="SASL_PLAINTEXT",
+ "property.sasl.mechanism"="PLAIN",
+ "property.sasl.username"="admin",
+ "property.sasl.password"="admin"
+ );
+
+ ```
+
<version since="1.2">
**Accessing a Kerberos-certified Kafka cluster**
diff --git a/docs/zh-CN/docs/data-operate/import/import-way/routine-load-manual.md b/docs/zh-CN/docs/data-operate/import/import-way/routine-load-manual.md
index e71523a1bb..db6c30ea12 100644
--- a/docs/zh-CN/docs/data-operate/import/import-way/routine-load-manual.md
+++ b/docs/zh-CN/docs/data-operate/import/import-way/routine-load-manual.md
@@ -389,6 +389,34 @@ eg: user_info 表的 json 数据
>
> [https://github.com/edenhill/librdkafka/blob/master/CONFIGURATION.md](https://github.com/edenhill/librdkafka/blob/master/CONFIGURATION.md)
+**访问 PLAIN 认证的 Kafka 集群**
+
+访问开启 PLAIN 认证的Kafka集群，需要增加以下配置：
+
+ - property.security.protocol=SASL_PLAINTEXT : 使用 SASL plaintext
+ - property.sasl.mechanism=PLAIN : 设置 SASL 的认证方式为 PLAIN
+ - property.sasl.username=admin : 设置 SASL 的用户名
+ - property.sasl.password=admin : 设置 SASL 的密码
+
+1. 创建例行导入作业
+
+ ```sql
+ CREATE ROUTINE LOAD db1.job1 on tbl1
+ PROPERTIES (
+ "desired_concurrent_number"="1",
+ )
+ FROM KAFKA
+ (
+ "kafka_broker_list" = "broker1:9092,broker2:9092",
+ "kafka_topic" = "my_topic",
+ "property.security.protocol"="SASL_PLAINTEXT",
+ "property.sasl.mechanism"="PLAIN",
+ "property.sasl.username"="admin",
+ "property.sasl.password"="admin"
+ );
+
+ ```
+
**访问 Kerberos 认证的 Kafka 集群**
<version since="1.2">
---------------------------------------------------------------------
To unsubscribe, e-mail: commits-unsubscribe@doris.apache.org
For additional commands, e-mail: commits-help@doris.apache.org