[camel-k-examples] 02/04: Kafka to SQL Server Example: Improved README

[ac...@apache.org]

This is an automated email from the ASF dual-hosted git repository.

acosentino pushed a commit to branch kafka-to-sqlserver
in repository https://gitbox.apache.org/repos/asf/camel-k-examples.git

commit c090b0029413a904aef96de6cb620cadf329e363
Author: Andrea Cosentino <an...@gmail.com>
AuthorDate: Thu Aug 5 07:20:10 2021 +0200

    Kafka to SQL Server Example: Improved README
---
 kamelets/kafka-to-sqlserver/README.md | 58 ++++++++++++++++++++++++++++++-----
 1 file changed, 50 insertions(+), 8 deletions(-)

diff --git a/kamelets/kafka-to-sqlserver/README.md b/kamelets/kafka-to-sqlserver/README.md
index af26143..cfe2972 100644
--- a/kamelets/kafka-to-sqlserver/README.md
+++ b/kamelets/kafka-to-sqlserver/README.md
@@ -1,18 +1,60 @@
-# Kafka to Kafka with Regex Router
+# Kafka to SQL Server
 
 - Use the quickstart for https://strimzi.io/quickstarts/ and follow the minikube guide.
 
-- The Log Sink Kamelet is not available out of the box in 1.5.0 Camel-K release so you'll have to install it before installing the flow binding.
-
 - If camel-k has been installed in a specific namespace different from the default one, you'll need to add a parameter to all the commands (-n <namespace_name>)
 
+- Run the following command
+
+    > kubectl run mssql-1 --image=mcr.microsoft.com/mssql/server:2017-latest --port=1433 --env 'ACCEPT_EULA=Y' --env 'SA_PASSWORD=Password!' -n kafka
+
+- Once the pod is up and running we'll need to create the table and populate it with same starting data
+
+    > kubectl -n kafka exec -it mssql-1 -- bash
+    > root@mssql-1:/# /opt/mssql-tools/bin/sqlcmd -S localhost -U SA -P "Password!"
+    1> CREATE TABLE accounts (user_id INT PRIMARY KEY, username VARCHAR ( 50 ) UNIQUE NOT NULL, city VARCHAR ( 50 ) NOT NULL );
+    2> GO
+    1> INSERT into accounts (user_id,username,city) VALUES (1, 'andrea', 'Roma');
+    2> GO
+    1> INSERT into accounts (user_id,username,city) VALUES (2, 'John', 'New York');
+    2> GO
+
+- So we now have two rows in the database.
+
+- Open a different terminal
+
+- Add the correct credentials and container address in the flow-binding yaml for the MSSQL Server database.
+
 - Run the following commands
 
-  - kubectl apply -f log-sink.kamelet.yaml -n kafka
-  - kubectl apply -f flow-binding.yaml -n kafka
+    kubectl apply -f flow-binding.yaml -n kafka
+
+- Open a different terminal and run the following command
+
+    kubectl -n kafka run kafka-producer -ti --image=quay.io/strimzi/kafka:0.24.0-kafka-2.8.0 --rm=true --restart=Never -- bin/kafka-console-producer.sh --broker-list my-cluster-kafka-bootstrap:9092 --topic test-topic-1
+
+- Send some messages to the kafka topic like for example
+
+    { "user_id":"3", "username":"Vittorio", "city":"Roma" } 
+    { "user_id":"4", "username":"Hugo", "city":"Paris" } 
+
+- Now we can check the database
+
+    > kubectl exec -it mssql-1 -- bash
+    > root@mssql-1:/# /opt/mssql-tools/bin/sqlcmd -S localhost -U SA -P "Password!"
+    1> SELECT * from accounts;
+    2> GO
+    user_id     username                                           city                                              
+    ----------- -------------------------------------------------- --------------------------------------------------
+                1 andrea                                             Roma                                              
+                2 John                                               New York                                          
+                3 Vittorio                                           Roma
+                4 Hugo                                               Paris                                               
+
+    (4 rows affected)
+
+- Check logs to see the integration running
 
-- Check logs
+    kamel logs kafka-to-sqlserver 
 
-kamel logs kafka-to-kafka-with-regex-router 
 
-You should data ingesting into the topic-1 topic, after regex router override the topic name.