Azure Event Hubs Connector Reference 1.1 - Mule 4

String

Tenant ID.

String

Client ID.

String

Client secret.

Boolean

When the application is deployed, a connectivity test is performed on all connectors. If set to true, deployment fails if the test doesn’t pass after exhausting the associated reconnection strategy.

Reconnection strategy to use.

Number

How often to attempt to reconnect, in milliseconds.

Boolean

If false, the reconnection strategy runs in a separate, non-blocking thread.

Number

How many reconnection attempts the Mule app can make.

Number

How often to attempt to reconnect, in milliseconds.

Boolean

If false, the reconnection strategy runs in a separate, non-blocking thread.

Number

Configures the maximum amount of time that a dynamic configuration instance can remain idle before Mule considers it eligible for expiration.

Enumeration, one of:

Time unit for the Max Idle Time field.

String

A MIME type describing the data contained in the EventBody, intended to allow consumers to make informed decisions for inspecting and processing the event.

String

Correlation ID.

DateTime

The date and time, in UTC, of when the event was enqueued in the Event Hub partition.

String

An application-defined value that uniquely identifies the event. The identifier is a free-form value and can reflect a GUID or an identifier derived from the application context.

Object

Custom data added to the Event, it exists only for coordination between event publishers and consumers.

Number

An offset is the position of an event within a partition.

Number

The sequence number assigned to the event when it was enqueued in the associated Event Hub partition.

Number

Initial amount of memory to allocate to the data stream. If the streamed data exceeds this value, the buffer expands by Buffer Size Increment, with an upper limit of Max In Memory Size value.

Number

This is by how much the buffer size expands if it exceeds its initial size. Setting a value of zero or lower means that the buffer should not expand, meaning that a STREAM_MAXIMUM_SIZE_EXCEEDED error is raised when the buffer gets full.

Number

Maximum size of the buffer. If the buffer size exceeds this value, Mule raises a STREAM_MAXIMUM_SIZE_EXCEEDED error. A value of less than or equal to 0 means no limit.

Enumeration, one of:

Unit for the Initial Buffer Size, Buffer Size Increment, and Buffer Unit fields.

Number

Maximum amount of memory that the stream can use for data. If the amount of memory exceeds this value, Mule buffers the content to disk. To optimize performance:

Enumeration, one of:

Unit for the In Memory Size field.

Number

Maximum number of times that a redelivered request can be processed unsuccessfully before returning a REDELIVERY_EXHAUSTED error.

String

Secure hashing algorithm to use if the Use Secure Hash field is true. If the payload of the message is a Java object, Mule ignores this value and returns the value that the payload’s hashCode() returned.

Redelivery Policy Message Identifier

One or more expressions that determine if a message was redelivered. This property can be set only if the Use Secure Hash field is false.

ObjectStore

Configures the object store that stores the redelivery counter for each message.

Boolean

If true, Mule uses a secure hash algorithm to identify a redelivered message.

String

One or more expressions that determine when a message was redelivered. You can set this property only if the Use Secure Hash field is false.

String

Body of the event.

Object

Metadata of the event.

Number

An offset is the position of an event within a partition.

x

Number

The sequence number assigned to the event when it was enqueued in the associated Event Hub partition.

x

String

Selects the enqueue time to start looking for an event.

x

String

Container name.

x

String

Account name of the Azure account.

x

String

Account key of the Azure account.

x

Token Credential Properties

Acquires a token via service principal authentication.

Boolean

Setting this flag to true, DefaultAzureCredential Class(Azure.Identity) is created to get a token to authenticate.

false

String

Container name.

x

String

Account name of the Azure account.

x

String

Specifies the Azure active directory host.

https://login.microsoftonline.com/

String

Event Hubs namespace name.

x

String

Shared access key name given by Azure

x

String

Shared access key value given by Azure.

x

String

Event Hub name.

x

Boolean

Toggles the builder to use the same connection for producers or consumers.

false

One of:

Select the checkpointing connection provider.

Token Credential Properties

Acquires a token via service principal authentication.

Boolean

Setting this flag to true, DefaultAzureCredential Class(Azure.Identity) is created to get a token to authenticate.

false

String

Event Hubs namespace name.

x

String

Specifies the Azure active directory host.

https://login.microsoftonline.com/

String

Event Hub name.

x

Boolean

Toggles the builder to use the same connection for producers or consumers.

false

One of:

Select the checkpointing connection provider.