This is an automated email from the ASF dual-hosted git repository.
jark pushed a commit to branch release-1.12
in repository https://gitbox.apache.org/repos/asf/flink.git
The following commit(s) were added to refs/heads/release-1.12 by this push:
new c7b89af [FLINK-20372][docs][kafka] Update Kafka SQL connector page to
mention 'properties.*' options
c7b89af is described below
commit c7b89af0bfd5165c82d3e69563d7b2c8cbaf59f0
Author: Shengkai <[email protected]>
AuthorDate: Tue Dec 8 19:20:53 2020 +0800
[FLINK-20372][docs][kafka] Update Kafka SQL connector page to mention
'properties.*' options
This closes #14276
---
docs/dev/table/connectors/kafka.md | 9 +++++++++
docs/dev/table/connectors/kafka.zh.md | 9 +++++++++
docs/dev/table/connectors/upsert-kafka.md | 9 +++++++++
docs/dev/table/connectors/upsert-kafka.zh.md | 11 +++++++++++
4 files changed, 38 insertions(+)
diff --git a/docs/dev/table/connectors/kafka.md
b/docs/dev/table/connectors/kafka.md
index 7e3891f..b2f036b 100644
--- a/docs/dev/table/connectors/kafka.md
+++ b/docs/dev/table/connectors/kafka.md
@@ -235,6 +235,15 @@ Connector Options
<td>The id of the consumer group for Kafka source, optional for Kafka
sink.</td>
</tr>
<tr>
+ <td><h5>properties.*</h5></td>
+ <td>optional</td>
+ <td style="word-wrap: break-word;">(none)</td>
+ <td>String</td>
+ <td>
+ This can set and pass arbitrary Kafka configurations. Suffix names
must match the configuration key defined in <a
href="https://kafka.apache.org/documentation/#configuration";>Kafka
Configuration documentation</a>. Flink will remove the "properties." key prefix
and pass the transformed key and values to the underlying KafkaClient. For
example, you can disable automatic topic creation via
<code>'properties.allow.auto.create.topics' = 'false'</code>. But there are
some configuratio [...]
+ </td>
+ </tr>
+ <tr>
<td><h5>format</h5></td>
<td>required</td>
<td style="word-wrap: break-word;">(none)</td>
diff --git a/docs/dev/table/connectors/kafka.zh.md
b/docs/dev/table/connectors/kafka.zh.md
index 0e6c108..e1227cc 100644
--- a/docs/dev/table/connectors/kafka.zh.md
+++ b/docs/dev/table/connectors/kafka.zh.md
@@ -235,6 +235,15 @@ Connector Options
<td>The id of the consumer group for Kafka source, optional for Kafka
sink.</td>
</tr>
<tr>
+ <td><h5>properties.*</h5></td>
+ <td>optional</td>
+ <td style="word-wrap: break-word;">(none)</td>
+ <td>String</td>
+ <td>
+ This can set and pass arbitrary Kafka configurations. Suffix names
must match the configuration key defined in <a
href="https://kafka.apache.org/documentation/#configuration";>Kafka
Configuration documentation</a>. Flink will remove the "properties." key prefix
and pass the transformed key and values to the underlying KafkaClient. For
example, you can disable automatic topic creation via
<code>'properties.allow.auto.create.topics' = 'false'</code>. But there are
some configuratio [...]
+ </td>
+ </tr>
+ <tr>
<td><h5>format</h5></td>
<td>required</td>
<td style="word-wrap: break-word;">(none)</td>
diff --git a/docs/dev/table/connectors/upsert-kafka.md
b/docs/dev/table/connectors/upsert-kafka.md
index 2bc39bc..9392c46 100644
--- a/docs/dev/table/connectors/upsert-kafka.md
+++ b/docs/dev/table/connectors/upsert-kafka.md
@@ -142,6 +142,15 @@ Connector Options
<td>Comma separated list of Kafka brokers.</td>
</tr>
<tr>
+ <td><h5>properties.*</h5></td>
+ <td>optional</td>
+ <td style="word-wrap: break-word;">(none)</td>
+ <td>String</td>
+ <td>
+ This can set and pass arbitrary Kafka configurations. Suffix names
must match the configuration key defined in <a
href="https://kafka.apache.org/documentation/#configuration";>Kafka
Configuration documentation</a>. Flink will remove the "properties." key prefix
and pass the transformed key and values to the underlying KafkaClient. For
example, you can disable automatic topic creation via
<code>'properties.allow.auto.create.topics' = 'false'</code>. But there are
some configuratio [...]
+ </td>
+ </tr>
+ <tr>
<td><h5>key.format</h5></td>
<td>required</td>
<td style="word-wrap: break-word;">(none)</td>
diff --git a/docs/dev/table/connectors/upsert-kafka.zh.md
b/docs/dev/table/connectors/upsert-kafka.zh.md
index f2f31e3..4432a9d 100644
--- a/docs/dev/table/connectors/upsert-kafka.zh.md
+++ b/docs/dev/table/connectors/upsert-kafka.zh.md
@@ -133,6 +133,17 @@ of all available metadata fields.
<td>以逗号分隔的 Kafka brokers 列表。</td>
</tr>
<tr>
+ <td><h5>properties.*</h5></td>
+ <td>可选</td>
+ <td style="word-wrap: break-word;">(none)</td>
+ <td>String</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。 但是，某些选项，例如<code>'key.deserializer'</code> 和
<code>'value.deserializer'</code> 是不允许通过该方式传递参数，因为 Flink 会重写这些参数的值。
+ </td>
+ </tr>
+ <tr>
<td><h5>key.format</h5></td>
<td>必选</td>
<td style="word-wrap: break-word;">(none)</td>
