Merge branch 'main' into latest

Author: cmilesb

content/integrate/redis-data-integration/data-pipelines/data-pipelines.md

@@ -28,8 +28,8 @@ However, you can also provide your own custom transformation [jobs](#job-files)
 for each source table, using your own data mapping and key pattern. You specify these
 jobs declaratively with YAML configuration files that require no coding.
 
-The data tranformation involves two separate stages. First, the data ingested by
-[Debezium](https://debezium.io/) is automatically transformed to a JSON format. Then,
+The data tranformation involves two separate stages. First, the data ingested
+during CDC is automatically transformed to a JSON format. Then,
 this JSON data gets passed on to your custom transformation for further processing.
 
 You can provide a job file for each source table you want to transform, but you
@@ -48,7 +48,7 @@ data in Redis as
 
 The diagram below shows the flow of data through the pipeline:
 
-{{< image filename="/images/rdi/data-transformation-pipeline.png" >}}
+{{< image filename="/images/rdi/RDIPipeDataflow.drawio.svg" >}}
 
 ## Pipeline configuration
 

content/integrate/redis-data-integration/observability.md

@@ -39,7 +39,7 @@ command from the CLI.{{< /note >}}
 
 ## Collector metrics
 
-The endpoint for the collector metrics is `https://<RDI_HOST>:9121/metrics/collector-source`
+The endpoint for the collector metrics is `https://<RDI_HOST>/metrics/collector-source`
 
 These metrics are divided into three groups:
 
@@ -49,7 +49,7 @@ These metrics are divided into three groups:
 
 ## Stream processor metrics
 
-The endpoint for the stream processor metrics is `https://<RDI_HOST>:9121/metrics/rdi`
+The endpoint for the stream processor metrics is `https://<RDI_HOST>/metrics/rdi`
 
 RDI reports metrics during the two main phases of the ingest pipeline, the *snapshot*
 phase and the *change data capture (CDC)* phase. (See the

content/operate/oss_and_stack/stack-with-enterprise/gears-v1/jvm/classes/readers/commandoverrider.md

@@ -51,26 +51,24 @@ CommandOverrider overrider = new CommandOverrider();
 overrider.setCommand("HSET");
 // Only override HSET for keys that start with "user:"
 overrider.setPrefix("user:");
-        
+
 // Create the data pipe builder
 GearsBuilder.CreateGearsBuilder(overrider).map(r-> {
-    // Extract the key from the command arguments
-    String keyName = new String((byte[]) r[1], StandardCharsets.UTF_8);
-        	
-    // Add a last_modified timestamp to the user's profile
-    GearsBuilder.execute("HSET", keyName, "last_modified", Long.toString(System.currentTimeMillis()));
-        	
-    // Get the original HSET arguments
-    ArrayList<String> commandArray = new ArrayList<String>();
-    for (int i=1; i < r.length; i++) {
-        commandArray.add(new String((byte[]) r[i], StandardCharsets.UTF_8));
+    // Get the operation arguments
+    ArrayList<String> operationArguments = new ArrayList<String>();
+    for (int i = 1; i < r.length; i++) {
+        operationArguments.add(new String((byte[]) r[i], StandardCharsets.UTF_8));
     }
-        	
-    // Run the original HSET command
-    GearsBuilder.callNext(commandArray.toArray(new String[0]));
-        	
-    return "OK";
-}).register();
+
+    // Add a last-modified field and a corresponding timestamp to the operation arguments
+    operationArguments.add("last-modified");
+    operationArguments.add(Long.toString(System.currentTimeMillis()));
+
+    // Run the enriched HSET operation
+    Object reply = GearsBuilder.callNext(operationArguments.toArray(new String[0]));
+    
+    return reply.toString();
+}).register(ExecutionMode.SYNC);
 ```
 
 After you register the previous code with the `RG.JEXECUTE` command, try to update the user's data with `HSET` to test it:

layouts/home.html

@@ -94,8 +94,8 @@ <h2 class="text-5xl font-medium" id="operate">Learn</h2>
           "LinksLeft" (slice
             (dict "Text" "RedisVL" "URL" "./integrate/redisvl/")
             (dict "Text" "RedisOM for Python" "URL" "./integrate/redisom-for-python")
-            (dict "Text" "Ingest" "URL" "./integrate/redis-data-integration/quickstart/ingest-guide/")
-            (dict "Text" "Write-behind" "URL" "./integrate/redis-data-integration/quickstart/write-behind-guide/")
+            (dict "Text" "Ingest" "URL" "./integrate/redis-data-integration/")
+            (dict "Text" "Write-behind" "URL" "./integrate/write-behind/quickstart/write-behind-guide/")
           )
         ) }}
         {{ partial "docs-section.html" (dict