azure-eventhub-checkpointstoreblob

What it is and what it does

This package integrates Azure Blob Storage as a persistent checkpoint store for Event Hubs consumers. When an EventHubConsumerClient processes events, it uses this checkpoint store to record which events have been consumed and to track partition ownership across multiple consumer instances. This enables consumer groups to resume from where they left off after a restart or failover, and allows multiple consumer instances to coordinate which partitions each one is reading from.

The package is a synchronous implementation that plugs directly into the EventHubConsumerClient. It stores checkpoint data (offsets, sequence numbers, partition ownership) as blobs in an Azure Storage container, making it suitable for distributed event processing architectures where consumer state must survive application restarts or be shared across multiple machines.

Use it for:

• Distributed event processing where multiple consumer instances coordinate via shared checkpoint state in Blob Storage.
• Resuming event consumption from the last processed position after application restarts or failures.
• Tracking partition ownership across a consumer group to ensure each partition is read by exactly one consumer.
• Replaying events by resetting checkpoints to earlier offsets when reprocessing is needed.
• Monitoring and auditing event consumption by querying checkpoint blobs for consumer progress.

Worth the install?

AI-flagged interpretation of the facts on this page — verify before relying

Provides a checkpoint store implementation for Azure Event Hubs consumers using Azure Blob Storage to persist consumer position and partition ownership data.

Yes. This is a production-stable, actively maintained package from Microsoft's official Azure SDK with no security vulnerabilities and low install friction. Install it if you are building an Event Hubs consumer application that requires durable, distributed checkpoint management. Do not install if you are using the async variant of Event Hubs or if you do not need persistent checkpoint storage.

Install

azure-eventhub-checkpointstoreblob on PyPI

pip install azure-eventhub-checkpointstoreblob

uv add azure-eventhub-checkpointstoreblob

poetry add azure-eventhub-checkpointstoreblob

Installing azure-eventhub-checkpointstoreblob

Before you install

Low install friction with a pure-Python wheel. Actively maintained as of 2025-02-13 with no known vulnerabilities. Depends on azure-core, azure-eventhub, cryptography, isodate, and typing-extensions—all standard Azure SDK components.

License in practice

MIT License (permissive). You may use, modify, and distribute this package freely in commercial and private projects with minimal restrictions.

Quickstart

from azure.eventhub import EventHubConsumerClient
from azure.eventhub.extensions.checkpointstoreblob import BlobCheckpointStore

checkpoint_store = BlobCheckpointStore.from_connection_string(
    storage_connection_str, container_name
)
client = EventHubConsumerClient.from_connection_string(
    connection_str, consumer_group, eventhub_name=eventhub_name,
    checkpoint_store=checkpoint_store
)
client.receive(on_event)

Requires an Azure subscription, an Event Hubs namespace with an Event Hub, and an Azure Storage Account with a Blob Storage Block Container already provisioned.

Verify before relying

• Whether the package supports async operations (description mentions an async variant exists separately).
• Performance characteristics when handling high-throughput event streams or many concurrent consumer groups.

Package facts

Evidence: azure_eventhub_checkpointstoreblob-1.2.0-py3-none-any.whl

Keywords: azure, azure sdk

Tags

More Distributed Computing packages