Description:
Receives messages from a Microsoft Azure Event Hub, writing the contents of the Azure message to the content of the FlowFile
Tags:
azure, microsoft, cloud, eventhub, events, streaming, streams
Properties:
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, and whether a property is considered “sensitive”, meaning that its value will be encrypted. Before entering a value in a sensitive property, ensure that the nifi.properties file has an entry for the property nifi.sensitive.props.key.
Name | Default Value | Allowable Values | Description |
Event Hub Name | The name of the Azure Event Hub to pull messages from | ||
Event Hub Namespace | The Azure Namespace that the Event Hub is assigned to. This is generally equal to <Event Hub Name>-ns | ||
Shared Access Policy Name | The name of the Event Hub Shared Access Policy. This Policy must have Listen permissions. | ||
Shared Access Policy Primary Key |
The primary key of the Event Hub Shared Access Policy Sensitive Property: true |
||
Number of Event Hub Partitions | The number of partitions that the Event Hub has. Only this number of partitions will be used, so it is important to ensure that if the number of partitions changes that this value be updated. Otherwise, some messages may not be consumed. | ||
Event Hub Consumer Group | $Default | The name of the Event Hub Consumer Group to use when pulling events |
Relationships:
Name | Description |
success | Any FlowFile that is successfully received from the Azure Event Hub will be transferred to this Relationship. |
Reads Attributes:
None specified.
Writes Attributes:
Name | Description |
eventhub.enqueued.timestamp | The time (in milliseconds since epoch, UTC) at which the message was enqueued in the Azure Event Hub |
eventhub.offset | The offset into the partition at which the message was stored |
eventhub.sequence | The Azure Sequence number associated with the message |
eventhub.name | The name of the Event Hub from which the message was pulled |
eventhub.partition | The name of the Azure Partition from which the message was pulled |