diff --git a/docs/dev/table/connectors/kafka.md b/docs/dev/table/connectors/kafka.md index 7e3891fd2c9f4..b2f036b80f8bc 100644 --- a/docs/dev/table/connectors/kafka.md +++ b/docs/dev/table/connectors/kafka.md @@ -234,6 +234,15 @@ Connector Options String The id of the consumer group for Kafka source, optional for Kafka sink. + +
properties.*
+ optional + (none) + String + + This can set and pass arbitrary Kafka configurations. Suffix names must match the configuration key defined in Kafka Configuration documentation. 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 'properties.allow.auto.create.topics' = 'false'. But there are some configurations that do not support to set, because Flink will override them, e.g. 'key.deserializer' and 'value.deserializer'. + +
format
required diff --git a/docs/dev/table/connectors/kafka.zh.md b/docs/dev/table/connectors/kafka.zh.md index 0e6c1086d2cf6..e1227cc168ead 100644 --- a/docs/dev/table/connectors/kafka.zh.md +++ b/docs/dev/table/connectors/kafka.zh.md @@ -234,6 +234,15 @@ Connector Options String The id of the consumer group for Kafka source, optional for Kafka sink. + +
properties.*
+ optional + (none) + String + + This can set and pass arbitrary Kafka configurations. Suffix names must match the configuration key defined in Kafka Configuration documentation. 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 'properties.allow.auto.create.topics' = 'false'. But there are some configurations that do not support to set, because Flink will override them, e.g. 'key.deserializer' and 'value.deserializer'. + +
format
required diff --git a/docs/dev/table/connectors/upsert-kafka.md b/docs/dev/table/connectors/upsert-kafka.md index 2bc39bced5646..9392c46e1eb75 100644 --- a/docs/dev/table/connectors/upsert-kafka.md +++ b/docs/dev/table/connectors/upsert-kafka.md @@ -141,6 +141,15 @@ Connector Options String Comma separated list of Kafka brokers. + +
properties.*
+ optional + (none) + String + + This can set and pass arbitrary Kafka configurations. Suffix names must match the configuration key defined in Kafka Configuration documentation. 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 'properties.allow.auto.create.topics' = 'false'. But there are some configurations that do not support to set, because Flink will override them, e.g. 'key.deserializer' and 'value.deserializer'. + +
key.format
required diff --git a/docs/dev/table/connectors/upsert-kafka.zh.md b/docs/dev/table/connectors/upsert-kafka.zh.md index f2f31e326007d..4432a9dde8526 100644 --- a/docs/dev/table/connectors/upsert-kafka.zh.md +++ b/docs/dev/table/connectors/upsert-kafka.zh.md @@ -132,6 +132,17 @@ of all available metadata fields. String 以逗号分隔的 Kafka brokers 列表。 + +
properties.*
+ 可选 + (none) + String + + 该选项可以传递任意的 Kafka 参数。选项的后缀名必须匹配定义在 Kafka 参数文档中的参数名。 + Flink 会自动移除 选项名中的 "properties." 前缀,并将转换后的键名以及值传入 KafkaClient。 例如,你可以通过 'properties.allow.auto.create.topics' = 'false' + 来禁止自动创建 topic。 但是,某些选项,例如'key.deserializer''value.deserializer' 是不允许通过该方式传递参数,因为 Flink 会重写这些参数的值。 + +
key.format
必选