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 2021/11/05 08:14:21 UTC

[camel-performance-tests] 01/02: Kafka Azure Storage Blob Example: Use application.properties to fill Kamelet parameters

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

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

commit 3347c2426c07aa9ab8ef10e6f251eb81e8c50c63
Author: Andrea Cosentino <an...@gmail.com>
AuthorDate: Fri Nov 5 09:12:49 2021 +0100

    Kafka Azure Storage Blob Example: Use application.properties to fill Kamelet parameters
---
 .../kafka-azure-storage-blob/data/application.properties   | 14 ++++++++++++++
 .../kafka-azure-storage-blob/data/sources/routes.yaml      |  7 -------
 2 files changed, 14 insertions(+), 7 deletions(-)

diff --git a/profiling/kafka-azure-storage-blob/data/application.properties b/profiling/kafka-azure-storage-blob/data/application.properties
index f725784..655ab42 100644
--- a/profiling/kafka-azure-storage-blob/data/application.properties
+++ b/profiling/kafka-azure-storage-blob/data/application.properties
@@ -28,3 +28,17 @@ 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-azure-storage-blob/data/sources/routes.yaml b/profiling/kafka-azure-storage-blob/data/sources/routes.yaml
index e813717..1905dfe 100644
--- a/profiling/kafka-azure-storage-blob/data/sources/routes.yaml
+++ b/profiling/kafka-azure-storage-blob/data/sources/routes.yaml
@@ -18,14 +18,7 @@
 - route:
     from: 
       uri: "kamelet:kafka-not-secured-source"
-      parameters:
-        brokers: "localhost:9092"
-        topic: "testtopic"
     steps:
       - to: 
           uri: "kamelet:azure-storage-blob-sink"
-          parameters:
-            containerName: "container"
-            accessKey: "accessKey"
-            accountName: "account"