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.git
The following commit(s) were added to refs/heads/main by this push:
new c203e7d4 Azure Eventhubs Source: Expose Kamelet data type information
(#1970)
c203e7d4 is described below
commit c203e7d4be6d97c2e56b5a3610a59b07510e303c
Author: Andrea Cosentino <[email protected]>
AuthorDate: Wed Mar 27 10:29:48 2024 +0100
Azure Eventhubs Source: Expose Kamelet data type information (#1970)
Signed-off-by: Andrea Cosentino <[email protected]>
---
kamelets/azure-eventhubs-source.kamelet.yaml | 66 +++++++++++++++++++++-
.../kamelets/azure-eventhubs-source.kamelet.yaml | 66 +++++++++++++++++++++-
2 files changed, 128 insertions(+), 4 deletions(-)
diff --git a/kamelets/azure-eventhubs-source.kamelet.yaml
b/kamelets/azure-eventhubs-source.kamelet.yaml
index b46b79de..095ffd23 100644
--- a/kamelets/azure-eventhubs-source.kamelet.yaml
+++ b/kamelets/azure-eventhubs-source.kamelet.yaml
@@ -87,9 +87,71 @@ spec:
type: string
enum: ["CONNECTION_STRING", "AZURE_IDENTITY"]
default: "CONNECTION_STRING"
- types:
+ dataTypes:
out:
- mediaType: application/octet-stream
+ default: binary
+ headers:
+ CamelAzureEventHubsPartitionId:
+ title: Azure Storage Event Hubs Partiton Id
+ description: It sets the partition id of the Event Hub.
+ type: string
+ CamelAzureEventHubsOffset :
+ title: Azure Storage Event Hubs Event Offset
+ description: It sets the offset of the event when it was received
from the associated Event Hub partition. This is only present on a received
EventData.
+ type: string
+ CamelAzureEventHubsEnqueuedTime:
+ title: Azure Event Hubs Event Enqueued Time
+ description: It sets the instant, in UTC, of when the event was
enqueued in the Event Hub partition. This is only present on a received
EventData.
+ type: java.time.Instant
+ CamelAzureEventHubsSequenceNumber:
+ title: Azure Event Hubs Event Sequence Number
+ description: |-
+ It sets the sequence number assigned to the event when it was
enqueued in the associated Event Hub partition. This is unique for every
message received in the Event Hub partition. This is only present on a received
EventData.
+ type: long
+ CamelAzureEventHubsMetadata:
+ title: Azure Event Hubs Event Metadata
+ description: The set of free-form event properties which may be used
for passing metadata associated with the event with the event body during Event
Hubs operations.
+ type: object
+ CamelMessageTimestamp:
+ title: Azure Event Hubs Message Timestamp
+ description: The timestamp of the message.
+ type: long
+ CamelAzureEventHubsCheckpointUpdatedBy:
+ title: Azure Event Hubs Checkpoint Updated By
+ description: It sets the reason for the checkpoint to have been
updated. This is only present on a received EventData.
+ type: string
+ types:
+ binary:
+ format: "application-octet-stream"
+ description: Default binary representation of the Azure Event Hubs
Event retrieved.
+ mediaType: application/octet-stream
+ cloudevents:
+ format: "azure-eventhubs:application-cloudevents"
+ description: |-
+ Data type transformer converts Azure Eventhubs consumer response
to CloudEvent v1_0 data format. The data type sets
+ Camel specific CloudEvent headers with values extracted from Azure
Eventhubs consumer response.
+ headers:
+ CamelCloudEventID:
+ title: CloudEvent ID
+ description: The Camel exchange id set as event id
+ type: string
+ CamelCloudEventType:
+ title: CloudEvent Type
+ description: The event type
+ default: "org.apache.camel.event.azure.eventhubs.consume"
+ type: string
+ CamelCloudEventSource:
+ title: CloudEvent Source
+ description: The event source. By default, the Partition Id with
prefix "azure.eventhubs.".
+ type: string
+ CamelCloudEventSubject:
+ title: CloudEvent Subject
+ description: The event subject. The Azure Event Hubs Event
Sequence Number.
+ type: string
+ CamelCloudEventTime:
+ title: CloudEvent Time
+ description: The exchange creation timestamp as event time.
+ type: string
dependencies:
- "camel:azure-eventhubs"
- "camel:kamelet"
diff --git
a/library/camel-kamelets/src/main/resources/kamelets/azure-eventhubs-source.kamelet.yaml
b/library/camel-kamelets/src/main/resources/kamelets/azure-eventhubs-source.kamelet.yaml
index b46b79de..095ffd23 100644
---
a/library/camel-kamelets/src/main/resources/kamelets/azure-eventhubs-source.kamelet.yaml
+++
b/library/camel-kamelets/src/main/resources/kamelets/azure-eventhubs-source.kamelet.yaml
@@ -87,9 +87,71 @@ spec:
type: string
enum: ["CONNECTION_STRING", "AZURE_IDENTITY"]
default: "CONNECTION_STRING"
- types:
+ dataTypes:
out:
- mediaType: application/octet-stream
+ default: binary
+ headers:
+ CamelAzureEventHubsPartitionId:
+ title: Azure Storage Event Hubs Partiton Id
+ description: It sets the partition id of the Event Hub.
+ type: string
+ CamelAzureEventHubsOffset :
+ title: Azure Storage Event Hubs Event Offset
+ description: It sets the offset of the event when it was received
from the associated Event Hub partition. This is only present on a received
EventData.
+ type: string
+ CamelAzureEventHubsEnqueuedTime:
+ title: Azure Event Hubs Event Enqueued Time
+ description: It sets the instant, in UTC, of when the event was
enqueued in the Event Hub partition. This is only present on a received
EventData.
+ type: java.time.Instant
+ CamelAzureEventHubsSequenceNumber:
+ title: Azure Event Hubs Event Sequence Number
+ description: |-
+ It sets the sequence number assigned to the event when it was
enqueued in the associated Event Hub partition. This is unique for every
message received in the Event Hub partition. This is only present on a received
EventData.
+ type: long
+ CamelAzureEventHubsMetadata:
+ title: Azure Event Hubs Event Metadata
+ description: The set of free-form event properties which may be used
for passing metadata associated with the event with the event body during Event
Hubs operations.
+ type: object
+ CamelMessageTimestamp:
+ title: Azure Event Hubs Message Timestamp
+ description: The timestamp of the message.
+ type: long
+ CamelAzureEventHubsCheckpointUpdatedBy:
+ title: Azure Event Hubs Checkpoint Updated By
+ description: It sets the reason for the checkpoint to have been
updated. This is only present on a received EventData.
+ type: string
+ types:
+ binary:
+ format: "application-octet-stream"
+ description: Default binary representation of the Azure Event Hubs
Event retrieved.
+ mediaType: application/octet-stream
+ cloudevents:
+ format: "azure-eventhubs:application-cloudevents"
+ description: |-
+ Data type transformer converts Azure Eventhubs consumer response
to CloudEvent v1_0 data format. The data type sets
+ Camel specific CloudEvent headers with values extracted from Azure
Eventhubs consumer response.
+ headers:
+ CamelCloudEventID:
+ title: CloudEvent ID
+ description: The Camel exchange id set as event id
+ type: string
+ CamelCloudEventType:
+ title: CloudEvent Type
+ description: The event type
+ default: "org.apache.camel.event.azure.eventhubs.consume"
+ type: string
+ CamelCloudEventSource:
+ title: CloudEvent Source
+ description: The event source. By default, the Partition Id with
prefix "azure.eventhubs.".
+ type: string
+ CamelCloudEventSubject:
+ title: CloudEvent Subject
+ description: The event subject. The Azure Event Hubs Event
Sequence Number.
+ type: string
+ CamelCloudEventTime:
+ title: CloudEvent Time
+ description: The exchange creation timestamp as event time.
+ type: string
dependencies:
- "camel:azure-eventhubs"
- "camel:kamelet"
