azure-eventhub-ts

What problem does it solve?

It provides a concise, developer-focused reference for building high-throughput event ingestion and real-time streaming pipelines with Azure Event Hubs using TypeScript, reducing integration friction and common mistakes.

Core Features & Use Cases

• Producer patterns: Efficient batched sends, partition targeting, and partition-key strategies for ordered streams.
• Consumer patterns: Partitioned consumers, configurable start positions, batch processing, and graceful shutdown with checkpointing.
• Operational concerns: Authentication options (DefaultAzureCredential or connection string), blob-based checkpoint stores, error handling, and monitoring of lag and partition properties.
• Use Case: Ingest IoT telemetry from thousands of devices into an Event Hub, process events in parallel consumers with blob checkpointing for safe resumption and load balancing.

Quick Start

Create a TypeScript producer and consumer that uses DefaultAzureCredential, sends events in batches, and uses BlobCheckpointStore to persist consumer checkpoints.