events.topic

The topic name to listen cassandra mutation events to

string

keyspace

Cassandra keyspace name

string

table

Cassandra table name

string

cloud.secureConnectBundle

The location of the cloud secure bundle used to connect to Datastax Astra DB.

string

""

compression

Compression algorithm to use when issuing requests to the database server

string

(case insensitive) [LZ4, NONE, SNAPPY]

None

connectionPoolLocalSize

Number of connections that driver maintains within a connection pool to each node in local dc

int

[1,…​]

4

contactPoints

Initial contact points

list

""

ignoreErrors

Specifies which errors the connector should ignore when processing the record. Valid values are: None (never ignore errors), All (ignore all errors), Driver (ignore driver errors only, i.e. errors when writing to the database).

string

None

jmx

Whether to enable JMX reporting

boolean

true

key.converter

Converter class used to write the message key to the data topic. This setting is experimental for advanced user only.

class

null

loadBalancing.localDc

The datacenter name (commonly dc1, dc2, etc.) local to the machine on which the connector is running

string

""

maxConcurrentRequests

The maximum number of requests to send at once

int

[1,…​]

500

metricsHighestLatency

This is used to scale internal data structures for gathering metrics. It should be higher than queryExecutionTimeout. This parameter should be expressed in seconds.

int

[1,…​]

35

port

Port to connect to nodes

int

[1,…​]

9042

queryExecutionTimeout

CQL statement execution timeout, in seconds

int

[1,…​]

30

value.converter

Converter class used to write the message value to the data topic. This setting is experimental for advanced user only.

class

null

batch.size

The batch size for grouping mutations before sending them to the data topic

int

200

query.backoffInMs

Retry backoff in milliseconds when there is not enough Cassandra replicas to perform the query. (Capped exponential jittered backoff)

long

100

query.executors

The initial and maximum number of threads to execute concurrent Cassandra queries

int

10

query.maxBackoffInSec

Maximum backoff delay in seconds when there is not enough Cassandra replicas to perform the query

long

3600

query.maxMobileAvgLatency

Maximum mobile average CQL query latency beyond which the number of executors is decreased

long

100

query.minMobileAvgLatency

Minimum mobile average CQL query latency beyond which the number of executors is increased

long

10

columns

Regular expression of the Cassandra replicated column names

string

.*

jmxConnectorDomain

Domain for JMX reporting

string

com.datastax.oss.cdc

events.subscription.name

The pulsar events topic subscription name, with a default set to 'sub'

string

sub

events.subscription.type

The pulsar events topic subscription type, with a default set to Key_Shared (case sensitive) for a non-partitioned events topic. If your events topic is partitioned, you should set subscription type to Failover

string

[Exclusive, Shared, Failover, Key_Shared]

Key_Shared

cache.max.digest

The maximum number of digest per mutation cache entry, with a default set to 3

long

[1,…​]

3

cache.max.capacity

The maximum capacity of the mutation cache, with a default size of 32767

long

[1,…​]

32767

cache.expire.after.ms

The mutation cache entry duration in milliseconds, with a default value of 60 seconds.

long

[1000,…​]

60000

cache.only_if_coordinator_match

Cache the mutation digest only if the coordinator node is the originator node.

boolean

true