[incubator-seatunnel] branch dev updated: [Fix] [Doc] Fix Kafka Doc Error Config Key "kafka." (#4427)

[ga...@apache.org]

This is an automated email from the ASF dual-hosted git repository.

gaojun2048 pushed a commit to branch dev
in repository https://gitbox.apache.org/repos/asf/incubator-seatunnel.git


The following commit(s) were added to refs/heads/dev by this push:
     new d323790ce [Fix] [Doc] Fix Kafka Doc Error Config Key "kafka." (#4427)
d323790ce is described below

commit d323790ce6bcf88cb45ce1936c919609b42d64f0
Author: Hisoka <fa...@qq.com>
AuthorDate: Mon Mar 27 18:22:11 2023 +0800

    [Fix] [Doc] Fix Kafka Doc Error Config Key "kafka." (#4427)
---
 docs/en/connector-v2/sink/Kafka.md | 22 ++++++++++++----------
 1 file changed, 12 insertions(+), 10 deletions(-)

diff --git a/docs/en/connector-v2/sink/Kafka.md b/docs/en/connector-v2/sink/Kafka.md
index 58160d1f2..38a0e488b 100644
--- a/docs/en/connector-v2/sink/Kafka.md
+++ b/docs/en/connector-v2/sink/Kafka.md
@@ -51,12 +51,10 @@ Currently two formats are supported:
 
 Kafka Brokers List.
 
-### kafka.* [kafka producer config]
+### kafka.config [kafka producer config]
 
 In addition to the above parameters that must be specified by the `Kafka producer` client, the user can also specify multiple non-mandatory parameters for the `producer` client, covering [all the producer parameters specified in the official Kafka document](https://kafka.apache.org/documentation.html#producerconfigs).
 
-The way to specify the parameter is to add the prefix `kafka.` to the original parameter name. For example, the way to specify `request.timeout.ms` is: `kafka.request.timeout.ms = 60000` . If these non-essential parameters are not specified, they will use the default values given in the official Kafka documentation.
-
 ### semantics [string]
 
 Semantics that can be chosen EXACTLY_ONCE/AT_LEAST_ONCE/NON, default NON.
@@ -156,9 +154,11 @@ sink {
       format = json
       kafka.request.timeout.ms = 60000
       semantics = EXACTLY_ONCE
-      kafka.security.protocol=SASL_SSL
-      kafka.sasl.mechanism=SCRAM-SHA-512
-      kafka.sasl.jaas.config="org.apache.kafka.common.security.scram.ScramLoginModule required \nusername=${username}\npassword=${password};"
+      kafka.config = {
+         security.protocol=SASL_SSL
+         sasl.mechanism=SCRAM-SHA-512
+         sasl.jaas.config="org.apache.kafka.common.security.scram.ScramLoginModule required \nusername=${username}\npassword=${password};"
+      }
   }
   
 }
@@ -190,10 +190,12 @@ sink {
       format = json
       kafka.request.timeout.ms = 60000
       semantics = EXACTLY_ONCE
-      kafka.security.protocol=SASL_SSL
-      kafka.sasl.mechanism=AWS_MSK_IAM
-      kafka.sasl.jaas.config="software.amazon.msk.auth.iam.IAMLoginModule required;"
-      kafka.sasl.client.callback.handler.class="software.amazon.msk.auth.iam.IAMClientCallbackHandler"
+      kafka.config = {
+         security.protocol=SASL_SSL
+         sasl.mechanism=AWS_MSK_IAM
+         sasl.jaas.config="software.amazon.msk.auth.iam.IAMLoginModule required;"
+         sasl.client.callback.handler.class="software.amazon.msk.auth.iam.IAMClientCallbackHandler"
+      }
   }
   
 }