Sink plugin : Kafka [Flink]
Write data to Kafka
name | type | required | default value |
---|---|---|---|
producer.bootstrap.servers | string | yes | - |
topic | string | yes | - |
producer.* | string | no | - |
common-options | string | no | - |
Kafka Brokers List
Kafka Topic
In addition to the above mandatory 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.
The way to specify the parameter is to add the prefix producer.
to the original parameter name. For example, the way to specify request.timeout.ms
is: producer.request.timeout.ms = 60000
. If these non-essential parameters are not specified, they will use the default values given in the official Kafka documentation.
Sink plugin common parameters, please refer to Sink Plugin for details
KafkaTable { producer.bootstrap.servers = "127.0.0.1:9092" topics = test_sink }