[Fix][Docs] Update jdbc doc and kafka doc (#4380)

Co-authored-by: chaorongzhi <[email protected]>
apache · Mar 22, 2023 · 801642f · 801642f
1 parent 4e52eba
commit 801642f
Show file tree

Hide file tree

Showing 2 changed files with 21 additions and 16 deletions.
diff --git a/docs/en/connector-v2/sink/Jdbc.md b/docs/en/connector-v2/sink/Jdbc.md
@@ -201,12 +201,13 @@ CDC(Change data capture) event
 ```
 sink {
     jdbc {
-        url = "jdbc:mysql://localhost:3306/test"
+        url = "jdbc:mysql://localhost:3306"
         driver = "com.mysql.cj.jdbc.Driver"
         user = "root"
         password = "123456"
         
-        table = sink_table
+        database = "sink_database"
+        table = "sink_table"
         primary_keys = ["key1", "key2", ...]
     }
 }

diff --git a/docs/en/connector-v2/source/kafka.md b/docs/en/connector-v2/source/kafka.md
@@ -157,13 +157,15 @@ source {
         topic = "seatunnel"
         bootstrap.servers = "xx.amazonaws.com.cn:9096,xxx.amazonaws.com.cn:9096,xxxx.amazonaws.com.cn:9096"
         consumer.group = "seatunnel_group"
-        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.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=SCRAM-SHA-512
+            sasl.jaas.config="org.apache.kafka.common.security.scram.ScramLoginModule required \nusername=${username}\npassword=${password};"
+            #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"
+        }
     }
 }
 ```
@@ -191,13 +193,15 @@ source {
         topic = "seatunnel"
         bootstrap.servers = "xx.amazonaws.com.cn:9098,xxx.amazonaws.com.cn:9098,xxxx.amazonaws.com.cn:9098"
         consumer.group = "seatunnel_group"
-        #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.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=SCRAM-SHA-512
+            #sasl.jaas.config="org.apache.kafka.common.security.scram.ScramLoginModule required \nusername=${username}\npassword=${password};"
+            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"
+        }
     }
 }
 ```