# General parameters

The following tables list parameters that are configurable in the distribution properties, unless specified. They can be added in the connection string or the separate configuration file of the Kafka connector.

For more details, see https://docs.confluent.io/platform/current/clients/librdkafka/html/md\_CONFIGURATION.html.

The tables are listed in big categories:

## To ensure the delivery of data

| Parameter | Description |
| --- | --- |
| bootstrap.servers (parameter in the Manager:<br>broker) | Indicates the number of acknowledgements the leader broker must<br>receive from ISR brokers before responding to the request:<br><br>By default, it is set to all (the process<br><br>waits until all in-sync replicas have received the data). |
| Acks (parameter in the Manager:<br>topic.acks or<br>topic.request.required.acks) | Indicates the number of acknowledgements the leader broker must<br>receive from ISR brokers before responding to the request:<br><br>By<br>default, it is set to all (the process waits<br>until all in-sync replicas have received the data). |

## In case of connection issues to the Kafka cluster

| Parameter | Description |
| --- | --- |
| Retries (parameter in the Manager:<br>retries or<br>message.send.max.retries) | Indicates the number of retries to send a failing message.<br><br>Information noteNote: Retrying may cause reordering unless<br>enable.idempotence is set to true.<br><br>By default, it is set to 1000000. |
| retry.backoff.ms (parameter in the Manager:<br>retry.backoff.ms) | Indicates the initial time to wait before reconnecting to a broker<br>after the connection has been closed.<br><br>By default, it is set to 100. |

## To preserve message order

| Parameter | Description |
| --- | --- |
| max.in.flight.requests.per.connection (parameter in the<br>Manager: max.in.flight.requests.per.connection or<br>max.in.flight) | Indicates the maximum number of in-flight requests per broker<br>connection.<br><br><br>By default, it is set to<br>1000000. |

## For performance running

| Parameter | Description |
| --- | --- |
| batch.size | Indicates the maximum size (in bytes) of all messages batched in one<br>MessageSet.<br><br>Information noteNote: This parameter is not configurable in the<br>distribution properties but other parameters are available and may<br>be equivalent:<br><br><ul> <li><span>queue.buffering.max.messages</span>: Maximum                                        number of messages allowed on the producer queue. This queue                                        is shared by all topics and partitions. </li> <li><span>queue.buffering.max.kbytes</span>: Maximum total                                        message size sum allowed on the producer queue. This queue                                        is shared by all topics and partitions. This property has                                        higher priority than                                            <span>queue.buffering.max.messages</span>. </li> <li><span>message.max.bytes</span>: Maximum Kafka protocol                                        request message size. </li> <li><span>message.copy.max.bytes</span>: Maximum size for                                        messages to be copied to the buffer. Messages larger than                                        this will be passed by reference (zero-copy) at the expense                                        of larger iovecs.</li> </ul> |
| linger.ms (parameter in the Manager:<br>linger.ms or<br>queue.buffering.max.ms) | Indicates the alias for queue.buffering.max.ms:<br>delay in milliseconds to wait for messages in the producer queue to<br>accumulate before constructing message batches (MessageSets) to transmit<br>to brokers.<br><br><br>By default, it is set to<br>1000000. |
| buffer.memory | Indicates the total bytes of memory the producer can use to buffer<br>records waiting to be sent to the server.<br><br>Information noteNote: This parameter is not<br>configurable in the distribution properties but other parameters are<br>available and may be equivalent: See<br>batch.size. |

## Transport Layer Authentication and Security

| Parameter | Description |
| --- | --- |
| security.protocol | Protocol used to communicate with brokers.<br><br>Possible values:<br>sasl\_ssl ,<br>ssl, sasl\_plaintext<br><br>Example:<br>security.protocol=sasl\_ssl |
| sasl.username | SASL username to be used with PLAIN and SASL-SCRAM<br>mechanisms. |
| sasl.password | SASL password to be used with the PLAIN and SASL-SCRAM<br>mechanisms. |
| sasl.mechanisms | SASL mechanism to be used for authentication.<br><br>Possible values:<br>GSSAPI, PLAIN,<br>SCRAM-SHA-256,<br>SCRAM-SHA-512,<br>OAUTHBEARER.<br><br>Example:<br>sasl.mechanisms=SCRAM-SHA-256 |
| ssl.ca.location | Path to the CA certificate to verify the broker key.<br><br>Example:<br>ssl.ca.location=%P%ca-cert.cert %P% will be<br>replaced by the DestinationPath\Data<br>path. |

## Talend Change Data Capture parameters

| Parameter | Description |
| --- | --- |
| config \| cfg \| cf | Path to the configuration file.<br><br>The parameters can be put in a<br>configuration file.<br><br>Example: config=%P%producer.config<br>%P% corresponds to Talend Change Data Capture data path: DestinationPath\Data. |
| tkey \| tk | Type of serialization of the key. The key is used internally by the<br>Kafka connector of Talend Change Data Capture. |
| codepage \| cp | Conversion file used by the target when the source is an AS/400 IBMi<br>machine. |
| tr | Allows to get metrics on topic for each partition in a log file. This<br>file is stored in the folder<br>.\DestinationPath\Data\Kafka\ and named<br>REE\_SSSMMM\_statKfk.log.<br><br>Metrics are saved<br>only when the distribution is stopped. |
| mode \| md | To enable or disable template script.<br><br>0=<br>Template script disabled<br><br>1 = Template<br>script enabled<br><br>0 = Default |