Merge pull request #1952 from rabbitmq/stream-tutorial-2

Stream Tutorial 2

Author: acogoluegnes

sidebarsTutorials.js

@@ -428,6 +428,11 @@ const sidebars = {
                     type: 'doc',
                     id: 'tutorial-one-java-stream',
                     label: 'Hello World',
+                },
+                {
+                    type: 'doc',
+                    id: 'tutorial-two-java-stream',
+                    label: 'Offset Tracking',
                 }
             ]
         },
@@ -439,6 +444,11 @@ const sidebars = {
                     type: 'doc',
                     id: 'tutorial-one-dotnet-stream',
                     label: 'Hello World',
+                },
+                {
+                    type: 'doc',
+                    id: 'tutorial-two-dotnet-stream',
+                    label: 'Offset Tracking',
                 }
             ]
         },
@@ -450,7 +460,13 @@ const sidebars = {
                     type: 'doc',
                     id: 'tutorial-one-go-stream',
                     label: 'Hello World',
+                },
+                {
+                    type: 'doc',
+                    id: 'tutorial-two-go-stream',
+                    label: 'Offset Tracking',
                 }
+
             ]
         },
         {

src/components/Tutorials/T2DiagramStreamToC.md

@@ -0,0 +1,12 @@
+```mermaid
+flowchart LR
+    P((P))
+    Q[[Stream-Queue]]
+    C((C))
+
+    P --> Q <--> C
+
+    class P mermaid-producer
+    class Q mermaid-queue
+    class C mermaid-consumer
+```

src/components/Tutorials/TutorialsStreamIntro.md

@@ -1,2 +1,2 @@
 RabbitMQ Streams was introduced in RabbitMQ 3.9.
-You can find more information [here](/docs/streams).
+More information is available [here](/docs/streams).

tutorials/index.md

@@ -27,6 +27,7 @@ import T6DiagramToC from '@site/src/components/Tutorials/T6DiagramToC.md';
 
 
 import T1DiagramStreamToC from '@site/src/components/Tutorials/T1DiagramStreamToC.md';
+import T2DiagramStreamToC from '@site/src/components/Tutorials/T2DiagramStreamToC.md';
 
 # RabbitMQ Tutorials
 
@@ -234,6 +235,18 @@ This section covers [RabbitMQ streams](/docs/streams).
     * [Node.js](tutorials/tutorial-one-javascript-stream)
   </td>
 
+  <td id="tutorial-two" style={{verticalAlign: 'top',}}>
+    ## 2. Offset Tracking
+
+    Keep track of message processing
+
+    <T2DiagramStreamToC/>
+    * [Java](tutorials/tutorial-two-java-stream)
+    * [C#](tutorials/tutorial-two-dotnet-stream)
+    * [Go](tutorials/tutorial-two-go-stream)
+  </td>
+
+
 </tr>
 
 </table>

tutorials/tutorial-one-dotnet-stream.md

@@ -88,6 +88,7 @@ cd Send
 dotnet add package RabbitMQ.Stream.Client 
 cd ../Receive
 dotnet add package RabbitMQ.Stream.Client 
+cd ..
 ```
 
 Now we have the .NET project set up we can write some code.

tutorials/tutorial-one-dotnet.md

@@ -88,7 +88,7 @@ mv Receive/Program.cs Receive/Receive.cs
 
 This will create two new directories named `Send` and `Receive`.
 
-Then we add the client dependency.
+Then add the client dependency.
 
 ```PowerShell
 cd Send

tutorials/tutorial-one-go-stream.md

@@ -74,6 +74,7 @@ Now let's create the project:
 ```shell
 mkdir go-stream
 cd go-stream
+go mod init github.com/rabbitmq/rabbitmq-tutorials
 go get -u github.com/rabbitmq/rabbitmq-stream-go-client
 ```
 

tutorials/tutorial-one-java-stream.md

@@ -38,7 +38,7 @@ import T1DiagramReceiving from '@site/src/components/Tutorials/T1DiagramReceivin
 
 In this part of the tutorial we'll write two programs in Java; a
 producer that sends a single message, and a consumer that receives
-messages and prints them out. We'll gloss over some of the detail in
+messages and prints them out. We'll gloss over some of the details in
 the Java client API, concentrating on this very simple thing just to get
 started. It's the "Hello World" of RabbitMQ Streams.
 
@@ -101,7 +101,7 @@ import com.rabbitmq.stream.*;
 import java.io.IOException;
 ```
 
-With these classes imported, en `Environment` now can be instantiated:
+With these classes imported, an `Environment` now can be instantiated:
 
 ```java
 Environment environment = Environment.builder().build();