diff --git a/docs/en/connector-v2/sink/Jdbc.md b/docs/en/connector-v2/sink/Jdbc.md index 479c935b98d..82d064d2fec 100644 --- 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 index 23ecad34321..75d910341fe 100644 --- 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" + } } } ```