Cassandra Sink Connector Configuration Options

The Cassandra Sink Connector Connector can be configured using a variety of configuration properties.

Connection

cassandra.contact.points

The Cassandra hosts to connect to.

  • Type: List
  • Importance: High
  • Default Value: [localhost]
cassandra.password

The password to connect to Cassandra with.

  • Type: Password
  • Importance: High
  • Default Value: [hidden]
cassandra.security.enabled

Flag to determine if security is enabled.

  • Type: Boolean
  • Importance: High
  • Default Value: true
cassandra.ssl.enabled

Flag to determine if SSL is enabled when connecting to Cassandra.

  • Type: Boolean
  • Importance: High
  • Default Value: false
cassandra.username

The username to connect to Cassandra with.

  • Type: String
  • Importance: High
  • Default Value: cassandra
cassandra.port

The port the Cassandra hosts are listening on.

  • Type: Int
  • Importance: Medium
  • Default Value: 9042
  • Valid Values: ValidPort{start=1025, end=65535}
cassandra.compression

Compression algorithm to use when connecting to Cassandra.

  • Type: String
  • Importance: Low
  • Default Value: NONE
  • Valid Values: [NONE, SNAPPY, LZ4]

Keyspace

cassandra.keyspace

The keyspace to write to.

  • Type: String
  • Importance: High
cassandra.keyspace.create.enabled

Flag to determine if the keyspace should be created if it does not exist.

  • Type: Boolean
  • Importance: High
  • Default Value: true

SSL

cassandra.ssl.truststore.password

Password to open the Java Truststore with.

  • Type: Password
  • Importance: Medium
  • Default Value: [hidden]
  • Valid Values: Empty String or Absolute path to a file that exists.
cassandra.ssl.truststore.path

Path to the Java Truststore.

  • Type: String
  • Importance: Medium
  • Valid Values: Empty String or Absolute path to a file that exists.
cassandra.ssl.provider

The SSL Provider to use when connecting to Cassandra

  • Type: String
  • Importance: Low
  • Default Value: JDK
  • Valid Values: JDK, OPENSSL, OPENSSL_REFCNT

Table

cassandra.table.manage.enabled

Flag to determine if the connector should manage the table.

  • Type: Boolean
  • Importance: High
  • Default Value: true
cassandra.table.create.caching

Caching setting to use.

  • Type: String
  • Importance: Medium
  • Default Value: NONE
  • Valid Values: ALL, KEYS_ONLY, ROWS_ONLY, NONE
cassandra.table.create.compression.algorithm

Compression algorithm to use when the table is created.

  • Type: String
  • Importance: Medium
  • Default Value: NONE
  • Valid Values: [NONE, SNAPPY, LZ4, DEFLATE]
cassandra.offset.storage.table

The table within the Cassandra keyspace to store the offsets that have been read from Apache Kafka®. This is used to enable exactly once delivery to Cassandra.

  • Type: String
  • Importance: Low
  • Default: kafka_connect_offsets

Write

cassandra.consistency.level

The requested consistency level to use when writing to Cassandra.

  • Type: String
  • Importance: High
  • Default Value: LOCAL_QUORUM
  • Valid Values: ANY, ONE, TWO, THREE, QUORUM, ALL, LOCAL_QUORUM, EACH_QUORUM, SERIAL, LOCAL_SERIAL, LOCAL_ONE
cassandra.deletes.enabled

Flag to determine if the connector should process deletes.

  • Type: Boolean
  • Importance: High
  • Default Value: true
cassandra.write.mode

The type of statement to build when writing to Cassandra.

  • Type: String
  • Importance: High
  • Default Value: Insert
cassandra.execute.timeout.ms

The timeout for executing a Cassandra statement.

  • Type: Long
  • Importance: Low
  • Default Value: 30000