Anonymitaet commented on a change in pull request #5210: [Doc] Add *Kafka sink 
connector guide*
URL: https://github.com/apache/pulsar/pull/5210#discussion_r325500145
 
 

 ##########
 File path: site2/docs/io-kafka-sink.md
 ##########
 @@ -0,0 +1,66 @@
+---
+id: io-kafka-sink
+title: Kafka sink connector
+sidebar_label: Kafka sink connector
+---
+
+The Kafka sink connector pulls messages from Pulsar topics and persists the 
messages
+to Kafka topics.
+
+This guide explains how to configure and use the Kafka sink connector.
+
+## Configuration
+
+The configuration of the Kafka sink connector has the following parameters.
+
+| Name | Type| Required | Default | Description 
+|------|----------|---------|-------------|-------------|
+|  `bootstrapServers` |String| true | " " (empty string) | A comma-separated 
list of host and port pairs for establishing the initial connection to the 
Kafka cluster. |
+|`ack`|String|true|" " (empty string) |The number of acknowledgments that the 
producer requires the leader to receive before a request completes. <br/>This 
controls the durability of the sent records.
+|`batchsize`|long||16384L|The batch size that a Kafka producer attempts to 
batch records together before sending them to brokers.
+|`maxRequestSize`|long||1048576L|The maximum size of a Kafka request in bytes.
+|`topic`|String|true|" " (empty string) |The Kafka topic which receives 
messages from Pulsar.
+| `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**.
+
 
 Review comment:
   @tuteng thank you, I've added.

----------------------------------------------------------------
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


With regards,
Apache Git Services

Reply via email to