DataStax connection

Configure the connection to the DataStax cluster.

Configure the connection settings from Apache Kafka™ to the DataStax database.

Parameters

connectionPoolLocalSize=4
contactPoints=[dse_host_list]
loadBalancing.localDc=datacenter_name
#port=9042
#maxConcurrentRequests=500
#maxNumberOfRecordsInBatch=32
#queryExecutionTimeout=30
#jmx=true
#compression=None
connectionPoolLocalSize
Number of connections that driver maintains within a connection pool to each node in the local datacenter.

Default: 4

contactPoints
A comma-separated list of DataStax Enterprise host names or IP addresses in square brackets.
Note: When this setting is specified (DataStax Enterprise database is on a remote host), the loadBalancing.localDc is required.

Default: localhost

loadBalancing.localDc
The case-sensitive datacenter name for the driver to use for load balancing.

Default: ""

port
DSE native transport port. See native_transport_port.

Default: 9042

maxConcurrentRequests
Maximum number of requests to send to DSE at the same time.

Default: 500

maxNumberOfRecordsInBatch
Number of records to include in a write request to the DataStax Enterprise database table.

Default: 32

jmx
Whether to enable metrics reporting using Java Management Extensions (JMX). See Monitoring DataStax Apache Kafka Connector.

Default: true

compression
Compression algorithm to use when issuing requests to DSE. Valid values are None, Snappy, and LZ4, which is applied per connector instance.

Default: None

queryExecutionTimeout
CQL statement execution timeout, in seconds.

Default: 30