Redis Data Integration Configuration File

Properties

NameTypeDescriptionRequired
applier
(Configuration details of Redis Data Integration Applier Gear)
object, null
connectionsobject

applier: Configuration details of Redis Data Integration Applier Gear

Properties

NameTypeDescriptionRequired
on_failed_retry_interval
(Interval (in seconds) on which to perform retry on failure)
integer, stringDefault: 5
Pattern: ^\${.*}$
Minimum: 1
read_batch_size
(The batch size for reading data from source database)
integer, stringDefault: 2000
Pattern: ^\${.*}$
Minimum: 1
debezium_lob_encoded_placeholder
(Enable Debezium LOB placeholders)
stringDefault: "X19kZWJleml1bV91bmF2YWlsYWJsZV92YWx1ZQ=="
dedup
(Enable deduplication mechanism)
booleanDefault: false
dedup_max_size
(Max size of the deduplication set)
integerDefault: 1024
Minimum: 1
duration
(Time (in ms) after which data will be read from stream even if read_batch_size was not reached)
integer, stringDefault: 100
Pattern: ^\${.*}$
Minimum: 1
write_batch_size
(The batch size for writing data to target Redis database. Should be less or equal to the read_batch_size)
integer, stringDefault: 200
Pattern: ^\${.*}$
Minimum: 1
error_handling
(Error handling strategy: ignore - skip, dlq - store rejected messages in a dead letter queue)
stringDefault: "dlq"
Pattern: ``^${.*}$
ignoredlq``
dlq_max_messages
(Dead letter queue max messages per stream)
integer, stringDefault: 1000
Pattern: ^\${.*}$
Minimum: 1
target_data_type
(Target data type: hash/json - RedisJSON module must be in use in the target DB)
stringDefault: "hash"
Pattern: ``^${.*}$
hashjson``
json_update_strategy
(Target update strategy: replace/merge - RedisJSON module must be in use in the target DB)
string(DEPRECATED)
Property ‘json_update_strategy’ will be deprecated in future releases. Use ‘on_update’ job-level property to define the json update strategy.
Default: "replace"
Pattern: ``^${.*}$
replacemerge``
initial_sync_processes
(Number of processes RDI Engine creates to process the initial sync with the source)
integer, stringDefault: 4
Pattern: ^\${.*}$
Minimum: 1
Maximum: 32
wait_enabled
(Checks if the data has been written to the replica shard)
booleanDefault: false
wait_timeout
(Timeout in milliseconds when checking write to the replica shard)
integer, stringDefault: 1000
Pattern: ^\${.*}$
Minimum: 1
retry_on_replica_failure
(Ensures that the data has been written to the replica shard and keeps retrying if not)
booleanDefault: true

Additional Properties: not allowed

connections: Connections

Properties (Pattern)

NameTypeDescriptionRequired
.*
additionalProperties