Configure ordering of outbound records
The record-ordering
section configures the ordering of records dispatched to the outbound
destination. When record-ordering
is enabled it guarantees all writes for a record (uniquely
identified by namespace and digest) from this connector instance to the outbound destination will
be in non-decreasing LUT (last update time) order.
This feature is implemented by maintaining a cache of the records along with its LUT (last update time). A new record, received from Aerospike XDR, is dispatched to the outbound destination only when the LUT of the new record is greater than or equal to the LUT of the cached instance. Also if the LUT of the new record is greater than or equal to the LUT of the cached instance, the LUT of the cached instance is updated to the LUT of this new record. If the new record has a lower LUT than the cached instance, then the record is rejected to Aerospike XDR with a temporary error, and Aerospike XDR will retry.
To keep the RAM memory consumed by the LUT (last update time) cache within reasonable bounds an
entry is deleted after a configured duration (lut-cache-ttl-seconds
)
elapses from the last update to the record’s LUT. Each LUT cache entry consumes about 256 bytes.
Cache entry size | Bytes per million cache entries | Number of entries per GiB |
---|---|---|
256 bytes | 244 MiB | Approximately 4.19 million cache entries. |
The options for the record-ordering
are as follows
Option | Default | Description |
---|---|---|
lut-cache-ttl-seconds | 30 | Time to live in seconds for a last update time (LUT) cache entry. An entry is deleted from the cache after lut-cache-ttl-seconds elapses from the last update to the record’s LUT. This must be configured to a value greater than the maximum delay a record can encounter between dispatch by Aerospike XDR to being received by the outbound connector. The delay might be caused by slow networks, VM pauses, VM migrations, or other factors. |
enable | true | Whether record ordering should be enabled. |
By default record-ordering
is disabled and needs to be explicitly enabled.
Examples
# lut-cache-ttl-seconds defaults to 30record-ordering: enable: true
# Explicitly disable record ordering.record-ordering: enable: false
# enable defaults to truerecord-ordering: lut-cache-ttl-seconds: 60
record-ordering: enable: true lut-cache-ttl-seconds: 60