From d7cc05502acc899337dd3524e1294a70ea9ee9fe Mon Sep 17 00:00:00 2001 From: yuanyuan8983 <99315889+yuanyuan8983@users.noreply.github.com> Date: Tue, 20 Jun 2023 23:19:59 +0800 Subject: [PATCH] [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" + ); + + ``` + **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 集群**