Skip to main content

AzureEventHubRecordSink

Description​

Format and send Records to Azure Event Hubs

Tags​

azure, record, sink

Properties​

In the list below required Properties are shown with an asterisk (*). Other properties are considered optional. The table also indicates any default values, and whether a property supports the NiFi Expression Language.

Display NameAPI NameDefault ValueAllowable ValuesDescription
Service Bus Endpoint *Service Bus EndpointAzure
  • Azure
  • Azure China
  • Azure Germany
  • Azure US Government
Provides the domain for connecting to Azure Event Hubs
Event Hub Namespace *Event Hub NamespaceProvides provides the host for connecting to Azure Event Hubs
Event Hub Name *Event Hub NameProvides the Event Hub Name for connections
Transport Type *Transport TypeAMQP
  • AMQP
  • AMQP_WEB_SOCKETS
Advanced Message Queuing Protocol Transport Type for communication with Azure Event Hubs
Record Writer *record-sink-record-writerController Service:
RecordSetWriterFactory

Implementations:
AvroRecordSetWriter
CSVRecordSetWriter
FreeFormTextRecordSetWriter
JsonRecordSetWriter
RecordSetWriterLookup
ScriptedRecordSetWriter
XMLRecordSetWriter		Specifies the Controller Service to use for writing out the records.
Authentication Strategy *Authentication StrategyDefault Azure Credential
  • Shared Access Key
  • Default Azure Credential
Strategy for authenticating to Azure Event Hubs
Shared Access PolicyShared Access PolicyThe name of the shared access policy. This policy must have Send claims

This property is only considered if:
  • the property Authentication Strategy has a value of SHARED_ACCESS_KEY
Shared Access Policy KeyShared Access Policy KeyThe primary or secondary key of the shared access policy

This property is only considered if:
  • the property Authentication Strategy has a value of SHARED_ACCESS_KEY
Partition KeyPartition KeyA hint for Azure Event Hub message broker how to distribute messages across one or more partitions

Supports Expression Language, using FlowFile attributes and Environment variables.

State Management​

This component does not store state.

Restricted​

This component is not restricted.

System Resource Considerations​

This component does not specify system resource considerations.

See Also​