[Doc] Add *Kafka sink connector guide* #5210
Conversation
| | `keyDeserializationClass` | String|false | org.apache.kafka.common.serialization.StringSerializer | The serializer class for Kafka producers to serialize keys. | ||
| | `valueDeserializationClass` | String|false | org.apache.kafka.common.serialization.ByteArraySerializer | The serializer class for Kafka producers to serialize values.<br/><br/>The serializer is set by a specific implementation of [`KafkaAbstractSink`](https://github.com/apache/pulsar/blob/master/pulsar-io/kafka/src/main/java/org/apache/pulsar/io/kafka/KafkaAbstractSink.java). | ||
| |`producerConfigProperties`|Map||" " (empty string)|The producer configuration properties to be passed to producers. <br/><br/>**Note: other properties specified in the connector configuration file take precedence over this configuration**. | ||
|
|
There was a problem hiding this comment.
@tuteng Are batchsize (line 20), maxRequestSize (line 21) and producerConfigProperties (line 25) optional or required?
I don't find this information in KafkaSinkConfig.java.
There was a problem hiding this comment.
optional, The required is true, indicating that it is necessary, otherwise, it is optional.
There was a problem hiding this comment.
@tuteng thank you, I've added.
|
|
||
| The Kafka sink connector pulls messages from Pulsar topics and persists the messages | ||
| to Kafka topics. | ||
|
|
There was a problem hiding this comment.
@tuteng are line7 and line8 accurate?
There was a problem hiding this comment.
@Anonymitaet yeah, it is correct.
There was a problem hiding this comment.
@murong00 thanks for your help
site2/docs/io-kafka-sink.md
Outdated
| sasl.mechanism: "GSSAPI" | ||
| sasl.kerberos.service.name: "kafka" | ||
| acks: "all" | ||
| ``` |
There was a problem hiding this comment.
@tuteng Is the format of this YAML file correct? (line 54-65)
|
run c++ tests |
sijie
added
component/connect
doc
|
run c++ tests |
1 similar comment
|
run c++ tests |
|
run cpp tests |
1 similar comment
|
run cpp tests |
Fix #5015