Compétences azure-eventhub-java
📦

azure-eventhub-java

Sûr

Azure Event Hubs Java SDK

Build real-time streaming applications with Azure Event Hubs SDK for Java. Use for event streaming, high-throughput data ingestion, and event-driven architectures.

Prend en charge: Claude Codex Code(CC)
🥉 75 Bronze
1

Télécharger le ZIP du skill

2

Importer dans Claude

Allez dans Paramètres → Capacités → Skills → Importer un skill

3

Activez et commencez Ă  utiliser

Tester

Utilisation de "azure-eventhub-java". Create an EventHubProducerClient with DefaultAzureCredential

RĂ©sultat attendu:

EventHubProducerClient producer = new EventHubClientBuilder()
.fullyQualifiedNamespace("<namespace>.servicebus.windows.net")
.eventHubName("<event-hub-name>")
.credential(new DefaultAzureCredentialBuilder().build())
.buildProducerClient();

Utilisation de "azure-eventhub-java". Send events in batch with partition key

RĂ©sultat attendu:

CreateBatchOptions options = new CreateBatchOptions()
.setPartitionKey("customer-123");
EventDataBatch batch = producer.createBatch(options);
batch.tryAdd(new EventData("Customer event"));
producer.send(batch);

Audit de sécurité

Sûr
v1 • 2/24/2026

All static findings are false positives. The skill is documentation for Azure Event Hubs Java SDK. The external_commands alerts (38 occurrences) are triggered by backticks in markdown code blocks - these are code examples, not shell commands. The weak_crypto and system_reconnaissance alerts are misinterpretations of documentation text (partition keys, checkpointing). No actual security risks present.

1
Fichiers analysés
362
Lignes analysées
0
résultats
1
Total des audits
Aucun problème de sécurité trouvé
Audité par: claude

Score de qualité

38
Architecture
100
Maintenabilité
85
Contenu
50
Communauté
100
Sécurité
100
Conformité aux spécifications

Ce que vous pouvez construire

Build event streaming pipelines

Create event producers and consumers for real-time data streaming between systems

Implement high-throughput data ingestion

Handle millions of events per second with batch processing and partition strategies

Create scalable microservices communication

Use Event Hubs as message backbone for microservices event-driven communication

Essayez ces prompts

Basic Event Producer 
Show me how to create an EventHubProducerClient using a connection string in Java
Event Consumer Setup 
How do I create an EventHubConsumerClient to receive events from a specific partition?
Production Event Processor 
Implement an EventProcessorClient with BlobCheckpointStore for production-scale processing
Async Event Handling 
Show me how to use EventHubProducerAsyncClient for non-blocking event sending

Bonnes pratiques

  • Use EventProcessorClient for production workloads to get automatic load balancing and checkpointing
  • Batch events using EventDataBatch for efficient network utilization
  • Always close clients using try-with-resources to ensure proper cleanup

Éviter

  • Do not hardcode connection strings in source code - use environment variables or Azure Key Vault
  • Avoid sending events one at a time - use batching for throughput
  • Do not skip checkpointing - this leads to reprocessing events on restart

Foire aux questions

What is the difference between EventHubProducerClient and EventHubProducerAsyncClient?
EventHubProducerClient is synchronous, blocking until operations complete. EventHubProducerAsyncClient is non-blocking and returns Mono/Flux for reactive programming patterns.
How do I choose a partition strategy?
Use partition keys for ordering within a specific category (like customer ID). Let Azure assign partitions for even distribution when ordering is not critical.
What is checkpointing and why is it important?
Checkpointing saves the position of processed events in Azure Blob Storage. This allows the processor to resume from where it left off after restarts or failures.
How do I handle transient errors?
Use the processError callback to catch AmqpException errors. Check isTransient() to identify errors that will be retried automatically.
Can I use managed identity instead of connection strings?
Yes, use DefaultAzureCredentialBuilder to authenticate with Azure Active Directory managed identities. This is recommended for production.
What is the difference between earliest and latest event position?
earliest() starts from the first available event in the partition. latest() starts from only new events arriving after the consumer connects.

Détails du développeur

Auteur

sickn33

Licence

MIT

DĂ©pĂ´t

https://github.com/sickn33/antigravity-awesome-skills/tree/main/skills/azure-eventhub-java

RĂ©f

main

Structure de fichiers

đź“„ SKILL.md