.. _datadiode-sink-connector-config:


Sink Configuration Properties
-----------------------------

To use this connector, specify the name of the connector class in the ``connector.class`` configuration property.

.. codewithvars:: properties

    connector.class=io.confluent.connect.diode.sink.DataDiodeSinkConnector

Connector-specific configuration properties are described below.


diode
^^^^^

``diode.encryption.password``
  The password used to derive a shared secret between the sink and source connectors. You must use the same password in sink and source connectors.

  * Type: password
  * Valid Values: non-empty string of a specific min length
  * Importance: high

``diode.host``
  The hostname or ip address of the remote server where this sink connector sends datagram packets.

  * Type: string
  * Importance: high

``diode.encryption.salt``
  The salt used to derive a shared secret between the sink and source connectors. You must use the same salt in sink and source connectors.

  * Type: password
  * Valid Values: non-empty string of a specific min length
  * Importance: high

``diode.port``
  The port number to connect to on the remote server.

  * Type: int
  * Default: 3456
  * Valid Values: [1024,...,65535]
  * Importance: high

``diode.buffer.size.kb``
  The maximum packet size in kilobytes.

  * Type: int
  * Default: 40
  * Valid Values: [1,...,64]
  * Importance: medium

``diode.encryption.class``
  Fully qualified class used for encrypting and decryption datagram packets. Currently, there are two implementations. ``io.confluent.connect.diode.serde.Aes256CbcEncryptor`` uses the AES algorithm with a 256 bit symmetric key derived from a password and salt. ``io.confluent.connect.diode.serde.NoopEncryptor`` disables encryption and decryption and sends  packets in plaintext. Custom encryption/decryption algorithms are possible by implementing ``io.confluent.connect.diode.serde.Encryptor``.

  * Type: class
  * Default: io.confluent.connect.diode.serde.Aes256CbcEncryptor
  * Importance: medium

``diode.compression.class``
  Fully qualified class used for compression and decompression on datagram packets. Compression is CPU intensive, but reduces size of packets. Enable compression if the records are largely text data. Compression is only effective if multiple records are batched. Currently, there are two implementations. ``io.confluent.connect.diode.serde.GzipCompressor`` for gzip and ``io.confluent.connect.diode.serde.NoopCompressor`` to disable compression. You can provied a different implementation by implementing ``io.confluent.connect.diode.serde.Compressor``.

  * Type: class
  * Default: io.confluent.connect.diode.serde.NoopCompressor
  * Importance: medium
  
.. _datadiode-sink-connector-license-config:

|cp| license
^^^^^^^^^^^^

``confluent.topic.bootstrap.servers``
A list of host/port pairs to use for establishing the initial connection to the Kafka cluster used for licensing. All servers in the cluster will be discovered from the initial connection. This list should be in the form <code>host1:port1,host2:port2,...</code>. Since these servers are just used for the initial connection to discover the full cluster membership (which may change dynamically), this list need not contain the full set of servers (you may want more than one, though, in case a server is down).

* Type: list
* Importance: high

``confluent.topic``
Name of the Kafka topic used for Confluent Platform configuration, including licensing information.

* Type: string
* Default: _confluent-command
* Importance: low

``confluent.topic.replication.factor``
The replication factor for the Kafka topic used for Confluent Platform configuration, including licensing information. This is used only if the topic does not already exist, and the default of 3 is appropriate for production use. If you are using a development environment with less than 3 brokers, you must set this to the number of brokers (often 1).

* Type: int
* Default: 3
* Importance: low

----------------------------
Confluent license properties
----------------------------

.. include:: ../includes/security-info.rst

.. include:: ../includes/platform-license.rst

.. include:: ../includes/security-configs.rst

.. _datadiode-sink-connector-license-topic-configuration:

.. include:: ../includes/platform-license-detail.rst

.. include:: ../includes/overriding-default-config-properties.rst