You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@camel.apache.org by ac...@apache.org on 2022/10/12 08:53:58 UTC

[camel-performance-tests] branch main updated: Kafka Azure Storage Blob: Updated docs and explicitly add parameters

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

acosentino pushed a commit to branch main
in repository https://gitbox.apache.org/repos/asf/camel-performance-tests.git


The following commit(s) were added to refs/heads/main by this push:
     new 806d00b  Kafka Azure Storage Blob: Updated docs and explicitly add parameters
806d00b is described below

commit 806d00b41d61f4e6ae6803406e8854a7c22a5d14
Author: Andrea Cosentino <an...@gmail.com>
AuthorDate: Wed Oct 12 10:53:19 2022 +0200

    Kafka Azure Storage Blob: Updated docs and explicitly add parameters
---
 profiling/kafka/kafka-azure-storage-blob/README.md         |  2 +-
 .../kafka-azure-storage-blob/data/application.properties   | 14 --------------
 .../data/sources/camel-jbang-route.yaml                    |  7 +++++++
 .../kafka-azure-storage-blob/data/sources/routes.yaml      | 13 ++++++++++---
 4 files changed, 18 insertions(+), 18 deletions(-)

diff --git a/profiling/kafka/kafka-azure-storage-blob/README.md b/profiling/kafka/kafka-azure-storage-blob/README.md
index d56bbd8..5f9f2d9 100644
--- a/profiling/kafka/kafka-azure-storage-blob/README.md
+++ b/profiling/kafka/kafka-azure-storage-blob/README.md
@@ -120,7 +120,7 @@ You could also leveraging the camel-jbang module. From Camel 3.15.0 (still to be
 What you need to do is simply running this commands:
 
 ```shell script
-jbang  -Dcamel.jbang.version=3.18.0-SNAPSHOT  camel@apache/camel run --jfr-profile=profile data/sources/camel-jbang-route.yaml
+jbang  -Dcamel.jbang.version=3.20.0-SNAPSHOT  camel@apache/camel run --jfr-profile=profile data/sources/camel-jbang-route.yaml
 ```
 
 You'll get at jfr recording file once the application will be stopped in your working directory.
diff --git a/profiling/kafka/kafka-azure-storage-blob/data/application.properties b/profiling/kafka/kafka-azure-storage-blob/data/application.properties
index 655ab42..f725784 100644
--- a/profiling/kafka/kafka-azure-storage-blob/data/application.properties
+++ b/profiling/kafka/kafka-azure-storage-blob/data/application.properties
@@ -28,17 +28,3 @@ camel.main.stream-caching-spool-directory = ${java.io.tmpdir}/camel-q
 camel.k.sources[0].location = file:/etc/camel/sources/routes.yaml
 camel.k.sources[0].type     = source
 
-
-#
-# Azure Storage Blob properties
-#
-camel.kamelet.azure-storage-blob-sink.containerName = containerName
-camel.kamelet.azure-storage-blob-sink.accessKey     = accessKey
-camel.kamelet.azure-storage-blob-sink.accountName   = accountName
-
-#
-# Kafka properties
-#
-camel.kamelet.kafka-not-secured-source.brokers = localhost:9092
-camel.kamelet.kafka-not-secured-source.topic   = testtopic
-
diff --git a/profiling/kafka/kafka-azure-storage-blob/data/sources/camel-jbang-route.yaml b/profiling/kafka/kafka-azure-storage-blob/data/sources/camel-jbang-route.yaml
index cc557f3..a14b91d 100644
--- a/profiling/kafka/kafka-azure-storage-blob/data/sources/camel-jbang-route.yaml
+++ b/profiling/kafka/kafka-azure-storage-blob/data/sources/camel-jbang-route.yaml
@@ -18,7 +18,14 @@
 - route:
     from: 
       uri: "kamelet:kafka-not-secured-source"
+      parameters:
+        bootstrapServers: "localhost:9092"
+        topic: "testtopic"
       steps:
         - to: 
             uri: "kamelet:azure-storage-blob-sink"
+            parameters:
+              accessKey: "accessKey"
+              accountName: "accountName"
+              containerName: "containerName"
 
diff --git a/profiling/kafka/kafka-azure-storage-blob/data/sources/routes.yaml b/profiling/kafka/kafka-azure-storage-blob/data/sources/routes.yaml
index 1905dfe..a14b91d 100644
--- a/profiling/kafka/kafka-azure-storage-blob/data/sources/routes.yaml
+++ b/profiling/kafka/kafka-azure-storage-blob/data/sources/routes.yaml
@@ -18,7 +18,14 @@
 - route:
     from: 
       uri: "kamelet:kafka-not-secured-source"
-    steps:
-      - to: 
-          uri: "kamelet:azure-storage-blob-sink"
+      parameters:
+        bootstrapServers: "localhost:9092"
+        topic: "testtopic"
+      steps:
+        - to: 
+            uri: "kamelet:azure-storage-blob-sink"
+            parameters:
+              accessKey: "accessKey"
+              accountName: "accountName"
+              containerName: "containerName"