Configure change notification for Aerospike Connect for Elasticsearch
For the complete documentation index see: llms.txt
All documentation pages available in markdown.
The change notification system informs the Aerospike Connect for Elasticsearch connector when records are inserted, modified, or deleted in an Aerospike database. This system uses Aerospike’s cross-datacenter replication (XDR) to publish changes as they occur.
Each message that the system sends contains either an updated/inserted record or a record deletion notification. Each update/insert/touch message contains the full database record including all, or a subset, of the record’s bins.
For Aerospike Database Enterprise Edition 5.0 and later, record deletion notifications contain:
- Namespace
- Record digest
- userKey (if available)
- set name (if available)
There might be instances where records are re-ordered on the network or across external systems, such as instances of source (outbound) connectors. In such cases, a message for an older version of a record might be delivered after a message for a newer version of the same record.
Prerequisites
- Aerospike Database Enterprise Edition, version 4.4 or later.
asdb-change-notificationset totruein your digitally-signed feature-key-file.
Procedure
To configure change notification for use with the Aerospike Elasticsearch Connector, follow these steps on each node of your Aerospike cluster:
-
Open the
/etc/aerospike/aerospike.confconfiguration file for editing. -
If there is no
xdrsection in the file, create one.xdr {} -
Create an XDR configuration in the
xdrsection, placing theconnectorproperty at the top of the configuration and setting its value totrue.Here is an example. The name
esDCis arbitrary. You can name your configurations as you see fit. In this example,esDCmeans only that the target “datacenter” is Elasticsearch.xdr {# Change notification XDR configuration that round-robins between two connector nodesdc esDC {connector truenode-address-port 10.0.0.1 8080node-address-port 10.0.0.2 8080namespace test {}}}For information about the properties in this example, see Configuration Parameter Reference.
-
Save and exit the file.
-
Restart the Aerospike cluster node.
Related information
- For a complete, runnable example that includes this XDR configuration, see:
- To learn how changes are logged, hot keys are optimized, and retransmits are handled, refer to the documentation for cross-datacenter replication: