AbstractEventHubTask

type: "io.kestra.plugin.azure.eventhubs.AbstractEventHubTask"

Properties

eventHubName

• Type: string
• Dynamic: ✔️
• Required: ✔️

The event hub to read from.

namespace

• Type: string
• Dynamic: ✔️
• Required: ✔️

Namespace name of the event hub to connect to.

clientMaxRetries

• Type: integer
• Dynamic: ❌
• Required: ❌
• Default: 5

The maximum number of retry attempts before considering a client operation to have failed.

clientRetryDelay

• Type: integer
• Dynamic: ❌
• Required: ❌
• Default: 500

The maximum permissible delay between retry attempts in milliseconds.

connectionString

• Type: string
• Dynamic: ✔️
• Required: ❌

Connection string of the Storage Account.

customEndpointAddress

• Type: string
• Dynamic: ✔️
• Required: ❌

Custom endpoint address when connecting to the Event Hubs service.

sasToken

• Type: string
• Dynamic: ✔️
• Required: ❌

The SAS token to use for authenticating requests.

This string should only be the query parameters (with or without a leading '?') and not a full URL.

sharedKeyAccountAccessKey

• Type: string
• Dynamic: ✔️
• Required: ❌

Shared Key access key for authenticating requests.

sharedKeyAccountName

• Type: string
• Dynamic: ✔️
• Required: ❌

Shared Key account name for authenticating requests.