Important

You are viewing documentation for an older version of Confluent Platform. For the latest, click here.

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]

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