You signed in with another tab or window. Reload to refresh your session.You signed out in another tab or window. Reload to refresh your session.You switched accounts on another tab or window. Reload to refresh your session.Dismiss alert
Copy file name to clipboardExpand all lines: content/integrate/redis-data-integration/ingest/_index.md
+2-2Lines changed: 2 additions & 2 deletions
Original file line number
Diff line number
Diff line change
@@ -54,10 +54,10 @@ RDI provides enterprise-grade streaming data pipelines with the following featur
54
54
[Prometheus](https://prometheus.io/) endpoints.
55
55
-**Observability - logs** - RDI saves rotating logs to a single folder. They are in a JSON format,
56
56
so you can collect and process them with your favorite observability tool.
57
-
-**Back-pressure mechanism** - RDI is designed to backoff writing data when the cache gets
57
+
-**Backpressure mechanism** - RDI is designed to backoff writing data when the cache gets
58
58
disconnected, which prevents cascading failure. Since the change data is persisted in the source
59
59
database and Redis is very fast, RDI can easily catch up with missed changes after a short period of
60
-
disconnection.
60
+
disconnection. See [Backpressure mechanism]({{< relref "/integrate/redis-data-integration/ingest/architecture #backpressure-mechanism">}}) for more information.
61
61
-**Recovering from full failure** - If the cache fails or gets disconnected for a long time,
62
62
RDI can reconstruct the cache data in Redis using a full snapshot of the defined dataset.
63
63
-**High throughput** - Because RDI uses Redis for staging and writes to Redis as a target,
Copy file name to clipboardExpand all lines: content/integrate/redis-data-integration/ingest/architecture.md
+17Lines changed: 17 additions & 0 deletions
Original file line number
Diff line number
Diff line change
@@ -68,6 +68,23 @@ RDI automatically enters a second phase called *change streaming*, where
68
68
changes in the data are captured as they happen. Changes are usually
69
69
added to the target within a few seconds after capture.
70
70
71
+
## Backpressure mechanism
72
+
73
+
Sometimes, data records can get added to the streams faster than RDI can
74
+
process them. This can happen if the target is slowed or disconnected
75
+
or simply if the source quickly generates a lot of change data.
76
+
If this continues, then the streams will eventually occupy all the
77
+
available memory. When RDI detects this situation, it applies a
78
+
*backpressure* mechanism to slow or stop the flow of incoming data.
79
+
Change data is held at the source until RDI clears the backlog and has
80
+
enough free memory to resume streaming.
81
+
82
+
{{<note>}}The Debezium log sometimes reports that RDI has run out
83
+
of memory (usually while creating the initial snapshot). This is not
84
+
an error, just an informative message to note that RDI has applied
85
+
the backpressure mechanism.
86
+
{{</note>}}
87
+
71
88
### Supported sources
72
89
73
90
RDI supports the following database sources using [Debezium Server](https://debezium.io/documentation/reference/stable/operations/debezium-server.html) connectors:
0 commit comments