How do I handle checkpoints in production?

Use the EventProcessorClient combined with a BlobCheckpointStore to store offsets in Azure Blob Storage, ensuring processing resumes from the last successful event after a restart.

Can I use this skill for asynchronous reactive processing?

Yes, the skill includes patterns for EventHubProducerAsyncClient and EventHubConsumerAsyncClient, allowing you to leverage Project Reactor for non-blocking event streams.

Does this skill help with partition-specific routing?

Yes, it provides implementation patterns for sending events to specific partition IDs or using partition keys to ensure related events are processed in the same order.

What is the best way to send multiple events efficiently?

Use the EventDataBatch class to group multiple events into a single network request. This maximizes throughput and ensures you stay within the maximum message size limits.

Azure Event Hubs Java Integration

Name: Azure Event Hubs Java Integration
Author: boisenoise

byboisenoise

•

Cloud Infrastructure

Streamlines the development of high-throughput, real-time event streaming applications using the Azure Event Hubs SDK for Java.

This skill provides Claude with specialized knowledge for implementing event-driven architectures and data ingestion pipelines using the Azure Event Hubs Java SDK. It offers ready-to-use patterns for creating producer and consumer clients, managing batches for performance, and implementing the production-ready EventProcessorClient with checkpointing. It is ideal for Java developers building scalable cloud-native applications on Azure that require reliable, high-volume message processing with built-in load balancing and error handling.

Key Features

01Production-grade EventProcessorClient implementation with Blob Storage checkpointing

02Efficient event batching patterns using EventDataBatch to optimize throughput

03Advanced partition management including specific IDs and partition key routing

042 GitHub stars

05Standardized client initialization for Producer, Consumer, and Async variants

06Built-in error handling strategies for transient AMQP exceptions and resource cleanup

Use Cases

01Building high-throughput telemetry or log ingestion pipelines for cloud applications

02Developing real-time data processing engines requiring distributed load balancing

03Implementing event-driven microservices architectures with reliable message delivery

What are Skills?·How to Install

Install with 🐟 Skill.Fish

npx skillfish add boisenoise/skills-collections antigravity-azure-eventhub-java

For use in Claude.ai and ChatGPT

Download Skill