Pass CDC for Cassandra settings directly to the DataStax Java driver
In your CDC for Cassandra configuration file, you can directly pass settings to the DataStax Java driver by using the datastax-java-driver prefix.
For example:
datastax-java-driver.basic.request.consistency=ALLMapping CDC for Cassandra settings to Java driver properties
The following table identifies functionally equivalent CDC for Cassandra and DataStax Java driver settings.
If you define both in your configuration, the CDC for Cassandra setting take precedence over the datastax-java-driver.property-name.
If you do not provide either in your configuration, CDC for Cassandra defaults are in effect.
|
For information about the Java properties, refer to the DataStax Java driver documentation.
| DataStax Cassandra Source Connector for Apache Pulsar™ | Using datastax-java-driver prefix |
|---|---|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
There is a difference between the CDC for Cassandra’s contactPoints setting and the Java driver’s datastax-java-driver.basic.contact-points.
For CDC for Cassandra’s contactPoints, the value of the port is appended to every host provided by this setting.
For datastax-java-driver.basic.contact-points, you must provide the fully qualified contact points (host:port).
By passing in the Java driver’s setting, this option gives you more configuration flexibility because you can specify a different port for each host. For example:
datastax-java-driver.basic.contact-points = 127.0.0.1:9042, 127.0.0.2:9042Java driver reference
For more information, refer to the Java driver reference configuration topic.