wuchong commented on a change in pull request #14276:
URL: https://github.com/apache/flink/pull/14276#discussion_r538000107
##########
File path: docs/dev/table/connectors/upsert-kafka.zh.md
##########
@@ -133,25 +133,15 @@ of all available metadata fields.
<td>以逗号分隔的 Kafka brokers 列表。</td>
</tr>
<tr>
- <td><h5>properties.sasl.kerberos.service.name</h5></td>
- <td>可选</td>
- <td style="word-wrap: break-word;">(none)</td>
- <td>String</td>
- <td>Kafka 运行使用的 Kerberos 的主体名称。 </td>
- </tr>
- <tr>
- <td><h5>properties.security.mechanism</h5></td>
+ <td><h5>properties.*</h5></td>
<td>optional</td>
<td style="word-wrap: break-word;">(none)</td>
<td>String</td>
- <td>用于客户端连接的 SASL mechanism。 可以是安全提供者提供的任何 mechanism。</td>
- </tr>
- <tr>
- <td><h5>properties.security.protocol</h5></td>
- <td>optional</td>
- <td style="word-wrap: break-word;">(none)</td>
- <td>String</td>
- <td>用于和 Kafka brokers 交流的任何协议。 可选的值有: PLAINTEXT, SSL, SASL_PLAINTEXT,
SASL_SSL。</td>
+ <td>
+ 该选项可以传递任意的 Kafka 参数。选项的后缀名必须是定义在 <a
href="https://kafka.apache.org/documentation/#configuration";>Kafka 参数文档</a>之中。
Review comment:
```suggestion
该选项可以传递任意的 Kafka 参数。选项的后缀名必须匹配定义在 <a
href="https://kafka.apache.org/documentation/#configuration";>Kafka
参数文档</a>中的参数名。
```
##########
File path: docs/dev/table/connectors/upsert-kafka.zh.md
##########
@@ -133,25 +133,15 @@ of all available metadata fields.
<td>以逗号分隔的 Kafka brokers 列表。</td>
</tr>
<tr>
- <td><h5>properties.sasl.kerberos.service.name</h5></td>
- <td>可选</td>
- <td style="word-wrap: break-word;">(none)</td>
- <td>String</td>
- <td>Kafka 运行使用的 Kerberos 的主体名称。 </td>
- </tr>
- <tr>
- <td><h5>properties.security.mechanism</h5></td>
+ <td><h5>properties.*</h5></td>
<td>optional</td>
<td style="word-wrap: break-word;">(none)</td>
<td>String</td>
- <td>用于客户端连接的 SASL mechanism。 可以是安全提供者提供的任何 mechanism。</td>
- </tr>
- <tr>
- <td><h5>properties.security.protocol</h5></td>
- <td>optional</td>
- <td style="word-wrap: break-word;">(none)</td>
- <td>String</td>
- <td>用于和 Kafka brokers 交流的任何协议。 可选的值有: PLAINTEXT, SSL, SASL_PLAINTEXT,
SASL_SSL。</td>
+ <td>
+ 该选项可以传递任意的 Kafka 参数。选项的后缀名必须是定义在 <a
href="https://kafka.apache.org/documentation/#configuration";>Kafka 参数文档</a>之中。
+ Flink 会自动移除 选项名中的 "properties." 前缀，并将转换后的键名以及值传入 KafkaClient。
例如，你可以通过 <code>'properties.allow.auto.create.topics' = 'false'</code>
+ 来禁止自动创建 topic。 但是，某些选项，例如`'key.deserializer'` 和
`'value.deserializer'` 是不允许通过该方式传递参数，因为 Flink 会重写这些参数的值。
Review comment:
```suggestion
来禁止自动创建 topic。 但是，某些选项，例如<code>'key.deserializer'</code> 和
<code>'value.deserializer'</code> 是不允许通过该方式传递参数，因为 Flink 会重写这些参数的值。
```
Use `<code>` to wrap code, markdown doesn't work in HTML table.
----------------------------------------------------------------
This is an automated message from the Apache Git Service.
To respond to the message, please log on to GitHub and use the
URL above to go to the specific comment.
For queries about this service, please contact Infrastructure at:
us...@infra.apache.org
