Azure Event Hubs

Learn the required and optional properties of creating a Azure Event Hubs Connection, Credential, Read Connector, and Write Connector.

Prerequisites

  • Event Hubs namespace in Azure with minimum Standard Pricing Tier.

Connection Properties

The following table describes the fields available when creating a new Azure Event Hubs Connection. Create a connection using the information below and these step-by-step instructions.

FieldRequiredDescription
Access TypeRequiredThis connection type is Read-Only, Write-Only, or Read-Write.
Connection NameRequiredInput your desired name.
Event Hubs Namespace HostnameRequiredThe hostname string in the format <NamespaceName>.servicebus.windows.net
Event Hubs IdentifierOptionalMust be unique and not the same as the Hostname.
Consumer Group IDOptionalConsumer group name. (Accessible through the Azure Event Hubs CLI.)
Consumer ConfigsOptionalAny additional configurations made to an event hub.
Skip Data Loss ErrorsOptionalBy default, Ascend will display an error and pause processing If Ascend encounters data loss. Selecting "Skip Data Loss Errors" lets Ascend ignore data loss and continue processing.
Requires CredentialsRequiredA Credential is required.

Credential Properties

The following table describes the fields available when creating a new Azure Event Hubs credential.

Field

Required

Description

Credential Name

Required

The name to identify this credential with. This credential will be available as a selection for future use.

Credential Type

Required

This field will automatically populate with Azure Event Hubs.

Connection Strings

Required

The Event Hubs connection string. Should be in the following format:
Endpoint=sb://<NamespaceName>.servicebus.windows.net/;SharedAccessKeyName=<KeyName>;SharedAccessKey=<KeyValue>

Read Connector Properties

The following table describes the fields available when creating a new Azure Even Hubs Read Connector. Create a new Read Connector using the information below and these step-by-step instructions.

Field

Required

Description

Name

Required

Provide a name for your connector. We recommend using lowercase with underscores in place of spaces.

Description

Optional

Describes the connector. We recommend providing a description if you are ingesting information from the same source multiple times for different reasons.

Subscription

Required

  • *Single Topic**: Topic to subscribe to
  • *Multi-Topic: **Provide a Topic Pattern to subscribe to all the topics matching the regex.

Key Deserializer

Required

Before transmitting the entire message to the broker, to let the producer know how to convert the message into byte array we use serializers.

  • String Deserializer: Convert byte array(containing string) to string
  • Binary Deserializer (B64 Encoded): Convert byte array (containing formats other than strings like AVRO) to Binary and then base64 encode it.

Value Deserializer

Required

To convert the byte array back to the object, indicate the deserializer by the consumer.

  • String Deserializer: Convert byte array(containing string) to string
  • Binary Deserializer (B64 Encoded): Convert byte array (containing formats other than strings like AVRO) to Binary and then base64 encode it.

Starting Position

Optional

Select the starting position. Earliest represents the start of the stream and Latest represents the end of the stream.

Consumer Configs

Optional

Include additional consumer Event Hub options.

Data Version

Optional

Assign a Data Version. A change to Data Version triggers the component to reprocess. It results in no longer using data previously ingested by this Connector, and a complete ingest of new data.

Write Connector Properties

The following table describes the fields available when creating a new Azure Event Hubs Write Connector. Create a new Write Connector using the information below and these step-by-step instructions.

Field

Required

Description

Name

Required

Provide a name for your connector. We recommend using lowercase with underscores in place of spaces.

Description

Optional

Describes the connector. We recommend providing a description if you are ingesting information from the same source multiple times for different reasons.

Upstream

Required

The name of the previous connector to pull data from.

Subscription

Required

  • *Single Topic**: Topic to subscribe to
  • *Multi-Topic: **Provide a Topic Pattern to subscribe to all the topics matching the regex.

Key Deserializer

Required

Before transmitting the entire message to the broker, to let the producer know how to convert the message into byte array we use serializers.

  • String Deserializer: Convert byte array(containing string) to string
  • Binary Deserializer (B64 Encoded): Convert byte array (containing formats other than strings like AVRO) to Binary and then base64 encode it.

Value Deserializer

Required

To convert the byte array back to the object, indicate the deserializer by the consumer.

  • String Deserializer: Convert byte array(containing string) to string
  • Binary Deserializer (B64 Encoded): Convert byte array (containing formats other than strings like AVRO) to Binary and then base64 encode it.

Starting Position

Optional

Select the starting position. Earliest represents the start of the stream and Latest represents the end of the stream

Producer Configs

Optional

Include additional producer Event Hub Options.

Data Version

Optional

Assign a Data Version. A change to Data Version triggers the component to reprocess. It results in no longer using data previously ingested by this Connector, and a complete ingest of new data.


© Ascension Labs Inc. | All Rights Reserved