ConsumeConsume
ConsumeCertified
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
SubTypestring
DefaultSTRING
Possible Values
STRINGBINARYIONJSON
Default{}
Default5
Default500
Default$Default
Default50
DefaultPT10S
Formatduration
DefaultPT5S
Formatduration
DefaultEARLIEST
Possible Values
EARLIESTLATESTINSTANT
Formaturi

More Plugins in this Category

Core Plugins and tasks
Core Plugins and tasks

Tasks that provide Kestra's built-in orchestration, I/O, and observability capabilities.

CoreStorageScript

126 Tasks

189 Blueprints

PostgreSQL
PostgreSQL

Tasks that connect to PostgreSQL via JDBC to run queries and loads.

Database

6 Tasks

8 Blueprints

SurrealDB
SurrealDB

Tasks that run SurrealQL queries against SurrealDB.

Database

2 Tasks

2 Blueprints
OVERVIEW
Versions
1.4.1
Latest
January 21, 2026 Release Notes Min. Compatible Kestra Version: 1.1.0
Previous Versions
1.4.0January 21, 2026 Min. Compatible Kestra Version: 1.1.0
1.3.1December 19, 2025 Min. Compatible Kestra Version: 1.1.0
1.3.0November 19, 2025 Min. Compatible Kestra Version: 1.1.0
1.2.0November 17, 2025 Min. Compatible Kestra Version: 1.1.0
1.1.4November 4, 2025 Min. Compatible Kestra Version: 1.1.0
1.1.3November 4, 2025 Min. Compatible Kestra Version: 1.1.0
1.1.2October 29, 2025 Min. Compatible Kestra Version: 1.0.6
1.1.1October 29, 2025 Min. Compatible Kestra Version: 1.0.6
1.0.2October 29, 2025 Min. Compatible Kestra Version: 1.0.0
1.1.0October 14, 2025 Min. Compatible Kestra Version: 1.0.6
1.0.1October 13, 2025 Min. Compatible Kestra Version: 1.0.0
1.0.0September 8, 2025 Min. Compatible Kestra Version: [1.0,)
0.24.1September 4, 2025 Min. Compatible Kestra Version: [0.24,)
0.24.0August 5, 2025 Min. Compatible Kestra Version: [0.24,)
0.24.0-rc1-SNAPSHOTJuly 31, 2025 Min. Compatible Kestra Version: [0.24,)
0.24.0-rc0-SNAPSHOTJuly 29, 2025 Min. Compatible Kestra Version: [0.23,)
0.23.0June 17, 2025 Min. Compatible Kestra Version: [0.23,0.24)
0.23.0-rc5-SNAPSHOTJune 16, 2025 Min. Compatible Kestra Version: [0.23,0.24)
0.23.0-rc4-SNAPSHOTJune 12, 2025 Min. Compatible Kestra Version: [0.23,0.24)
0.23.0-rc3-SNAPSHOTJune 10, 2025 Min. Compatible Kestra Version: [0.23,0.24)
0.23.0-rc2-SNAPSHOTJune 9, 2025 Min. Compatible Kestra Version: [0.22,)
0.23.0-rc1-SNAPSHOTJune 4, 2025 Min. Compatible Kestra Version: [0.22,)
0.23.0-rc0-SNAPSHOTJune 3, 2025 Min. Compatible Kestra Version: [0.22,)
0.22.3June 3, 2025 Min. Compatible Kestra Version: [0.22,0.23)
0.22.2May 20, 2025 Min. Compatible Kestra Version: [0.22,0.23)
0.22.0April 1, 2025 Min. Compatible Kestra Version: [0.22,)
0.22.0-rc4-SNAPSHOTMarch 31, 2025 Min. Compatible Kestra Version: [0.22,)
0.22.0-rc2-SNAPSHOTMarch 28, 2025 Min. Compatible Kestra Version: [0.22,)
0.22.0-rc1-SNAPSHOTMarch 25, 2025 Min. Compatible Kestra Version: [0.22,)

Created by

Kestra Core Team

Managed by

Kestra Core Team
Plugin Type
CloudMessagingStorageBatchToolDatabase
Links & Resources
GitHub