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"