Habilidades azure-eventhub-java
📦

azure-eventhub-java

Seguro

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.

Soporta: Claude Codex Code(CC)
🥉 75 Bronce
1

Descargar el ZIP de la skill

2

Subir en Claude

Ve a Configuración → Capacidades → Skills → Subir skill

3

Activa y empieza a usar

Pruébalo

Usando "azure-eventhub-java". Create an EventHubProducerClient with DefaultAzureCredential

Resultado esperado:

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

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

Resultado esperado:

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

Auditoría de seguridad

Seguro
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
Archivos escaneados
362
Líneas analizadas
0
hallazgos
1
Auditorías totales
No se encontraron problemas de seguridad
Auditado por: claude

Puntuación de calidad

38
Arquitectura
100
Mantenibilidad
85
Contenido
50
Comunidad
100
Seguridad
100
Cumplimiento de la especificación

Lo que puedes crear

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

Prueba estos 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

Mejores prácticas

  • 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

Evitar

  • 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

Preguntas frecuentes

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.

Detalles del desarrollador

Autor

sickn33

Licencia

MIT

Repositorio

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

Ref.

main

Estructura de archivos

📄 SKILL.md