Azure.Messaging.EventHubs.Primitives Namespace

Reference

Important

Some information relates to prerelease product that may be substantially modified before it’s released. Microsoft makes no warranties, express or implied, with respect to the information provided here.

Classes

BlobCheckpointStore	Allows interaction with checkpoint and ownership data needed for event processor operation, using Azure Storage blobs for persistence.
CheckpointStore	Allows interaction with checkpoint and ownership data needed for event processor operation.
EventProcessor<TPartition>	Provides a base for creating a custom processor which consumes events across all partitions of a given Event Hub for a specific consumer group. The processor is capable of collaborating with other instances for the same Event Hub and consumer group pairing to share work by using a common storage platform to communicate. Fault tolerance is also built-in, allowing the processor to be resilient in the face of errors.
EventProcessorCheckpoint	Contains the information to reflect the state of event processing for a given Event Hub partition.
EventProcessorOptions	The set of options that can be specified when creating an EventProcessor<TPartition> to configure its behavior.
EventProcessorPartition	A set of contextual information about an Event Hub partition for which an EventProcessor<TPartition> operation is being performed.
EventProcessorPartitionOwnership	The set of information for describing the status of the partition ownership between EventProcessor<TPartition> instances cooperating for distribution of processing for a given Event Hub.
PartitionReceiver	Allows reading events from a specific partition of an Event Hub, and in the context of a specific consumer group, to be read with a greater level of control over communication with the Event Hubs service than is offered by other event consumers.
PartitionReceiverOptions	The set of options that can be specified when creating a PartitionReceiver to configure its behavior.
PluggableCheckpointStoreEventProcessor<TPartition>	Provides a base for creating an event processor with custom processing logic which consumes events across all partitions of a given Event Hub for a specific consumer group. The processor is capable of collaborating with other instances for the same Event Hub and consumer group pairing to share work by using a common storage platform to communicate. Fault tolerance is also built-in, allowing the processor to be resilient in the face of errors.