Does this skill support partition-specific routing?

Yes, it provides implementation patterns for sending events to specific partition IDs or using partition keys to ensure related events are sent to the same partition for ordered processing.

How does the skill handle Azure authentication?

The skill utilizes DefaultAzureCredential from the @azure/identity library, which automatically supports environment variables, Managed Identities, and local developer credentials.

How do I ensure reliable event processing in production?

Use the @azure/eventhubs-checkpointstore-blob package alongside the consumer client to store partition offsets in Azure Blob Storage, allowing your application to resume processing after a restart.

Can I process events in batches to improve performance?

Yes, the skill demonstrates how to use createBatch() for producers and how to configure maxBatchSize and maxWaitTimeInSeconds for consumers to optimize throughput.

Azure Event Hubs for TypeScript

Name: Azure Event Hubs for TypeScript
Author: sickn33

bysickn33

•

24,380

•

Cloud Infrastructure

Builds high-throughput event streaming and real-time data ingestion applications using the Azure Event Hubs SDK for TypeScript.

This skill provides comprehensive patterns and best practices for implementing event-driven architectures using the Azure Event Hubs SDK for TypeScript. It guides developers through the entire lifecycle of event processing, including secure authentication with Azure Identity, efficient batch production, and reliable consumption with production-grade checkpointing using Azure Blob Storage. Whether you are building IoT telemetry pipelines, real-time analytics, or microservices communication, this skill ensures your implementation follows industry standards for scalability and fault tolerance.

Key Features

01Optimized event production using batching and partition-specific routing

0224,380 GitHub stars

03Secure authentication using DefaultAzureCredential and Managed Identity

04Production-ready checkpointing with Azure Blob Storage for exactly-once processing

05Robust error handling for transient and fatal messaging failures

06Flexible consumption from earliest, latest, or specific time-based offsets

Use Cases

01Implementing event-driven microservices with partition-key based ordering

02Ingesting and processing massive volumes of real-time IoT device telemetry

03Streaming application logs and metrics to real-time analytics dashboards

What are Skills?·How to Install

Install with 🐟 Skill.Fish

npx skillfish add sickn33/antigravity-awesome-skills azure-eventhub-ts

For use in Claude.ai and ChatGPT

Download Skill