Skip to content

Commit d323790

Browse files
authoredMar 27, 2023
[Fix] [Doc] Fix Kafka Doc Error Config Key "kafka." (apache#4427)
1 parent a80386a commit d323790

File tree

1 file changed

+12
-10
lines changed

1 file changed

+12
-10
lines changed
 

‎docs/en/connector-v2/sink/Kafka.md

+12-10
Original file line numberDiff line numberDiff line change
@@ -51,12 +51,10 @@ Currently two formats are supported:
5151

5252
Kafka Brokers List.
5353

54-
### kafka.* [kafka producer config]
54+
### kafka.config [kafka producer config]
5555

5656
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).
5757

58-
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.
59-
6058
### semantics [string]
6159

6260
Semantics that can be chosen EXACTLY_ONCE/AT_LEAST_ONCE/NON, default NON.
@@ -156,9 +154,11 @@ sink {
156154
format = json
157155
kafka.request.timeout.ms = 60000
158156
semantics = EXACTLY_ONCE
159-
kafka.security.protocol=SASL_SSL
160-
kafka.sasl.mechanism=SCRAM-SHA-512
161-
kafka.sasl.jaas.config="org.apache.kafka.common.security.scram.ScramLoginModule required \nusername=${username}\npassword=${password};"
157+
kafka.config = {
158+
security.protocol=SASL_SSL
159+
sasl.mechanism=SCRAM-SHA-512
160+
sasl.jaas.config="org.apache.kafka.common.security.scram.ScramLoginModule required \nusername=${username}\npassword=${password};"
161+
}
162162
}
163163
164164
}
@@ -190,10 +190,12 @@ sink {
190190
format = json
191191
kafka.request.timeout.ms = 60000
192192
semantics = EXACTLY_ONCE
193-
kafka.security.protocol=SASL_SSL
194-
kafka.sasl.mechanism=AWS_MSK_IAM
195-
kafka.sasl.jaas.config="software.amazon.msk.auth.iam.IAMLoginModule required;"
196-
kafka.sasl.client.callback.handler.class="software.amazon.msk.auth.iam.IAMClientCallbackHandler"
193+
kafka.config = {
194+
security.protocol=SASL_SSL
195+
sasl.mechanism=AWS_MSK_IAM
196+
sasl.jaas.config="software.amazon.msk.auth.iam.IAMLoginModule required;"
197+
sasl.client.callback.handler.class="software.amazon.msk.auth.iam.IAMClientCallbackHandler"
198+
}
197199
}
198200
199201
}

0 commit comments

Comments
 (0)
Please sign in to comment.