Pulsar topic-to-table settings

Capture Apache Pulsar™ topics in the supported database by specifying a target keyspace, table, and then map the topic fields to table columns in the name of the parameter.


Use the following syntax for standalone properties file:

topics: topic_list
        mapping: mapping_specification
        consistencyLevel: WRITE_CONSISTENCY_LEVEL
        ttlTimeUnit: seconds
        ttl: -1
        nullToUnset: true
        deletesEnabled: true

A comma separated list of all topics to which the DataStax Connector subscribes.


  • topic_name - Pulsar topic name.

  • keyspace_name - database keyspace where the table is located.

  • table_name - database table where data is written.


Required, field-to-column mapping. See Mapping pulsar topics to database tables.


Query consistency level. DSE settings are:


Whether to treat nulls in Pulsar as UNSET in DSE. DataStax recommends using the default to avoid creating unnecessary tombstones.

Default: true


Time-to-live. Set to the number of seconds before the data is automatically deleted from the DSE table. When you configure topic.<topic-name>.<keyspace-name>.<table-name>.ttl, all rows for that topic table will have this same TTL value. DataStax Pulsar Connector appends AND TTL <configured-ttl-value> to the INSERT statement for those rows.

Default: -1 (disabled)


When enabled, treat records that after mapping would result in only non-null values for primary key columns as deletes, rather than inserting/updating nulls for all regular columns.

Only triggers if the setting is enabled and the mapping specification contains all DSE table columns.

Default: true

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