DataStax connection

Configure the connection settings from Apache Pulsar™ to the cluster.

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 host names or IP addresses in square brackets.

When this setting is specified (for example, the database is on a remote host), the loadBalancing.localDc parameter is required.

Default: localhost

loadBalancing.localDc

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

You cannot use this option if specifying the [cloud.secureConnectBundle](pulsarConnector.md#secure_ConnectBundle) option for connecting to a DataStax Astra database.

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 database table.

Default: 32

jmx

Whether to enable metrics reporting using Java Management Extensions (JMX).

Default: true

compression

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

Default: None

queryExecutionTimeout

CQL statement execution timeout, in seconds.

Default: 30

Was this helpful?

Give Feedback

How can we improve the documentation?

© 2024 DataStax | Privacy policy | Terms of use

Apache, Apache Cassandra, Cassandra, Apache Tomcat, Tomcat, Apache Lucene, Apache Solr, Apache Hadoop, Hadoop, Apache Pulsar, Pulsar, Apache Spark, Spark, Apache TinkerPop, TinkerPop, Apache Kafka and Kafka are either registered trademarks or trademarks of the Apache Software Foundation or its subsidiaries in Canada, the United States and/or other countries. Kubernetes is the registered trademark of the Linux Foundation.

General Inquiries: +1 (650) 389-6000, info@datastax.com