Plugin AzureEventhubs

Consume ​Consume

yaml
type: "io.kestra.plugin.azure.eventhubs.consume"
yaml
id: azure_eventhubs_consume_data_events
namespace: company.team

tasks:
  - id: consume_from_eventhub
    type: io.kestra.plugin.azure.eventhubs.Consume
    eventHubName: my_eventhub
    namespace: my_eventhub_namespace
    connectionString: "{{ secret('EVENTHUBS_CONNECTION') }}"
    bodyDeserializer: JSON
    consumerGroup: "$Default"
    checkpointStoreProperties:
      containerName: kestra
      connectionString: "{{ secret('BLOB_CONNECTION') }}"
Properties
SubType string
Default STRING
Possible Values
STRINGBINARYIONJSON
Default {}
Default 5
Default 500
Default $Default
Default 50
Default PT10S
Format duration
Default PT5S
Format duration
Default EARLIEST
Possible Values
EARLIESTLATESTINSTANT
Format uri