Receives messages from Microsoft Azure Event Hubs without reliable checkpoint tracking. In clustered environment, GetAzureEventHub processor instances work independently and all cluster nodes process all messages (unless running the processor in Primary Only mode). ConsumeAzureEventHub offers the recommended approach to receiving messages from Azure Event Hubs. This processor creates a thread pool for connections to Azure Event Hubs.


azure, microsoft, cloud, eventhub, events, streaming, streams


In the list below, the names of required properties appear in bold. Any other properties (not in bold) are considered optional. The table also indicates any default values.

Display NameAPI NameDefault ValueAllowable ValuesDescription
Event Hub NamespaceEvent Hub NamespaceNamespace of Azure Event Hubs prefixed to Service Bus Endpoint domain
Event Hub NameEvent Hub NameName of Azure Event Hubs source
Service Bus EndpointService Bus EndpointAzure
  • Azure Servicebus endpoint for general use
  • Azure China Servicebus endpoint for China
  • Azure Germany Servicebus endpoint for Germany
  • Azure US Government Servicebus endpoint for US Government
To support namespaces not in the default domain.
Transport TypeTransport TypeAMQP
  • AMQP AMQP over TCP on ports 5671 and 5672
  • AMQP_WEB_SOCKETS AMQP over HTTPS with WebSockets on port 443
Advanced Message Queuing Protocol Transport Type for communication with Azure Event Hubs
Shared Access Policy NameShared Access Policy NameThe name of the shared access policy. This policy must have Listen claims.
Shared Access Policy KeyShared Access Policy Primary KeyThe key of the shared access policy. Either the primary or the secondary key can be used.
Sensitive Property: true
Use Azure Managed Identityuse-managed-identityfalse
  • true
  • false
Choose whether or not to use the managed identity of Azure VM/VMSS
Number of Event Hub PartitionsNumber of Event Hub PartitionsThis property is deprecated and no longer used.
Consumer GroupEvent Hub Consumer Group$DefaultThe name of the consumer group to use when pulling events
Message Enqueue TimeEvent Hub Message Enqueue TimeA timestamp (ISO-8601 Instant) formatted as YYYY-MM-DDThhmmss.sssZ (2016-01-01T01:01:01.000Z) from which messages should have been enqueued in the Event Hub to start reading from
Partition Receiver Fetch SizePartition Recivier Fetch SizeThe number of events that a receiver should fetch from an Event Hubs partition before returning. The default is 100
Partition Receiver TimeoutPartition Receiver Timeout (millseconds)The amount of time in milliseconds a Partition Receiver should wait to receive the Fetch Size before returning. The default is 60000
Proxy Configuration Serviceproxy-configuration-serviceController Service API:
Implementation: StandardProxyConfigurationService
Specifies the Proxy Configuration Controller Service to proxy network requests. Supported proxies: HTTP + AuthN

This Property is only considered if the [Transport Type] Property has a value of "AMQP_WEB_SOCKETS".


successAny FlowFile that is successfully received from the event hub will be transferred to this Relationship.

Reads Attributes:

None specified.

Writes Attributes:

eventhub.enqueued.timestampThe time (in milliseconds since epoch, UTC) at which the message was enqueued in the event hub
eventhub.offsetThe offset into the partition at which the message was stored
eventhub.sequenceThe Azure sequence number associated with the message
eventhub.nameThe name of the event hub from which the message was pulled
eventhub.partitionThe name of the event hub partition from which the message was pulled*The application properties of this message. IE: 'application' would be ''

State management:

This component does not store state.


This component is not restricted.

Input requirement:

This component does not allow an incoming relationship.

System Resource Considerations:

None specified.

See Also: