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 2023/10/20 12:31:13 UTC
[camel-kamelets-examples] branch main updated (713833f -> 47cd067)
This is an automated email from the ASF dual-hosted git repository.
acosentino pushed a change to branch main
in repository https://gitbox.apache.org/repos/asf/camel-kamelets-examples.git
from 713833f Azure Schema Registry Example: Align docs to show the working example with Camel 4.x (#35)
new 94bb97a Azure Schema Registry: Add an example with Kamelet too to consume from Azure Eventhubs Kafka
new 85f7188 Azure Schema Registry: Generic namespace
new 47cd067 Azure Schema Registry: Add an example with Kamelet too to consume from Azure Eventhubs Kafka
The 3 revisions listed above as "new" are entirely new to this
repository and will be described in separate emails. The revisions
listed as "add" were already present in the repository and have only
been added to this reference.
Summary of changes:
.../README.md | 6 ++++++
.../kafka-kamelet-log.yaml} | 16 ++++++++++------
.../azure-eventhubs-kafka-azure-schema-registry/main.tf | 2 +-
3 files changed, 17 insertions(+), 7 deletions(-)
copy jbang/{kafka-apicurio-schema-registry/kafka-apicurio-kamelet.yaml => azure-eventhubs-kafka-azure-schema-registry/kafka-kamelet-log.yaml} (72%)
[camel-kamelets-examples] 03/03: Azure Schema Registry: Add an example with Kamelet too to consume from Azure Eventhubs Kafka
Posted by ac...@apache.org.
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-kamelets-examples.git
commit 47cd067ecf1d1041765e6114809c23f0cbc88626
Author: Andrea Cosentino <an...@gmail.com>
AuthorDate: Fri Oct 20 14:28:49 2023 +0200
Azure Schema Registry: Add an example with Kamelet too to consume from Azure Eventhubs Kafka
Signed-off-by: Andrea Cosentino <an...@gmail.com>
---
jbang/azure-eventhubs-kafka-azure-schema-registry/README.md | 6 ++++++
1 file changed, 6 insertions(+)
diff --git a/jbang/azure-eventhubs-kafka-azure-schema-registry/README.md b/jbang/azure-eventhubs-kafka-azure-schema-registry/README.md
index 53ed25e..b23a03d 100644
--- a/jbang/azure-eventhubs-kafka-azure-schema-registry/README.md
+++ b/jbang/azure-eventhubs-kafka-azure-schema-registry/README.md
@@ -57,6 +57,12 @@ then run:
camel run kafka-log.yaml
```
+You can also use the Kamelet for working with Azure Schema Registry and Azure Eventhubs Kafka
+
+```bash
+jbang --fresh run camel@apache/camel run --local-kamelet-dir=<path_to_your_local_kamelets> --kamelets-version=4.1.0-SNAPSHOT kafka-kamelet-log.yaml
+```
+
To run the example without JBang, but e.g. Spring Boot, You can export the route:
```bash
camel export application.properties kafka-log.yaml --runtime=spring-boot --directory=code --gav com.acme.example:azure-sr:1.0.0
[camel-kamelets-examples] 02/03: Azure Schema Registry: Generic namespace
Posted by ac...@apache.org.
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-kamelets-examples.git
commit 85f71884678f1e7f1590c8c98e3ef6a5a3cd1307
Author: Andrea Cosentino <an...@gmail.com>
AuthorDate: Fri Oct 20 14:20:20 2023 +0200
Azure Schema Registry: Generic namespace
Signed-off-by: Andrea Cosentino <an...@gmail.com>
---
jbang/azure-eventhubs-kafka-azure-schema-registry/main.tf | 2 +-
1 file changed, 1 insertion(+), 1 deletion(-)
diff --git a/jbang/azure-eventhubs-kafka-azure-schema-registry/main.tf b/jbang/azure-eventhubs-kafka-azure-schema-registry/main.tf
index 8337e17..ba4fe6d 100644
--- a/jbang/azure-eventhubs-kafka-azure-schema-registry/main.tf
+++ b/jbang/azure-eventhubs-kafka-azure-schema-registry/main.tf
@@ -39,7 +39,7 @@ resource "azurerm_resource_group" "example" {
# Eventhubs Namepsace.
resource "azurerm_eventhub_namespace" "example" {
- name = "example-test12345-namespace"
+ name = "example-namespace"
location = azurerm_resource_group.example.location
resource_group_name = azurerm_resource_group.example.name
sku = "Standard"
[camel-kamelets-examples] 01/03: Azure Schema Registry: Add an example with Kamelet too to consume from Azure Eventhubs Kafka
Posted by ac...@apache.org.
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-kamelets-examples.git
commit 94bb97a85f772ca128f2d841a56c708591ecc7d6
Author: Andrea Cosentino <an...@gmail.com>
AuthorDate: Fri Oct 20 14:19:34 2023 +0200
Azure Schema Registry: Add an example with Kamelet too to consume from Azure Eventhubs Kafka
Signed-off-by: Andrea Cosentino <an...@gmail.com>
---
.../kafka-kamelet-log.yaml | 43 ++++++++++++++++++++++
.../main.tf | 4 +-
2 files changed, 45 insertions(+), 2 deletions(-)
diff --git a/jbang/azure-eventhubs-kafka-azure-schema-registry/kafka-kamelet-log.yaml b/jbang/azure-eventhubs-kafka-azure-schema-registry/kafka-kamelet-log.yaml
new file mode 100644
index 0000000..1e13d04
--- /dev/null
+++ b/jbang/azure-eventhubs-kafka-azure-schema-registry/kafka-kamelet-log.yaml
@@ -0,0 +1,43 @@
+## ---------------------------------------------------------------------------
+## Licensed to the Apache Software Foundation (ASF) under one or more
+## contributor license agreements. See the NOTICE file distributed with
+## this work for additional information regarding copyright ownership.
+## The ASF licenses this file to You under the Apache License, Version 2.0
+## (the "License"); you may not use this file except in compliance with
+## the License. You may obtain a copy of the License at
+##
+## http://www.apache.org/licenses/LICENSE-2.0
+##
+## Unless required by applicable law or agreed to in writing, software
+## distributed under the License is distributed on an "AS IS" BASIS,
+## WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
+## See the License for the specific language governing permissions and
+## limitations under the License.
+## ---------------------------------------------------------------------------
+
+# camel-k: dependency=mvn:com.acme.example:azure-identity:0.1
+
+- beans:
+ - name: defaultAzureCredential
+ type: "com.acme.example.azure.DefaultAzureCredentialWrapper"
+ - name: order
+ type: "com.acme.example.eventhubs.models.Order"
+
+- route:
+ id: "kafka-to-log"
+ from:
+ uri: "kamelet:kafka-azure-schema-registry-source"
+ parameters:
+ topic: "{{topic}}"
+ bootstrapServers: "{{bootstrap.servers}}"
+ consumerGroup: 'azure-consumer-group'
+ password: "{{password}}"
+ azureRegistryUrl: '{{schema.registry.url}}'
+ specificAvroValueType: 'com.acme.example.eventhubs.models.Order'
+ steps:
+ - to:
+ uri: "kamelet:log-sink"
+ parameters:
+ showStreams: true
+ showHeaders: true
+ multiline: true
diff --git a/jbang/azure-eventhubs-kafka-azure-schema-registry/main.tf b/jbang/azure-eventhubs-kafka-azure-schema-registry/main.tf
index d0da4a2..8337e17 100644
--- a/jbang/azure-eventhubs-kafka-azure-schema-registry/main.tf
+++ b/jbang/azure-eventhubs-kafka-azure-schema-registry/main.tf
@@ -39,7 +39,7 @@ resource "azurerm_resource_group" "example" {
# Eventhubs Namepsace.
resource "azurerm_eventhub_namespace" "example" {
- name = "example-namespace"
+ name = "example-test12345-namespace"
location = azurerm_resource_group.example.location
resource_group_name = azurerm_resource_group.example.name
sku = "Standard"
@@ -72,4 +72,4 @@ resource "azurerm_eventhub_namespace_schema_group" "example" {
namespace_id = azurerm_eventhub_namespace.example.id
schema_compatibility = "Forward"
schema_type = "Avro"
-}
\ No newline at end of file
+}