--- id: azure-eventhub-checkpointstoreblob version: "1.2.0" license: MIT License license_treatment: permissive maintenance: active --- # azure-eventhub-checkpointstoreblob — Microsoft Azure Event Hubs checkpointer implementation with Blob Storage Client Library for Python License: permissive · Maintenance: active · Downloads: 445.1K/mo ## 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 above — 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 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 - License: MIT License (permissive) - Python support: supports_current - Install friction: low - Maintenance: active - Downloads: 445.1K/month (top 15,000 on PyPI) - Known vulnerabilities: none known ## Tags azure event hubs checkpoint store, blob storage checkpoint persistence, event consumer offset tracking, azure eventhub consumer group state, distributed event processing checkpoints, azure storage blob event tracking, partition ownership management, azure-sdk, event-streaming, checkpoint-store [View on SkillFed](https://skillfed.io/packages/azure-eventhub-checkpointstoreblob) · [View on PyPI](https://pypi.org/project/azure-eventhub-checkpointstoreblob/)