Fähigkeiten azure-eventhub-java
📦

azure-eventhub-java

Sicher

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.

UnterstĂĽtzt: Claude Codex Code(CC)
🥉 72 Bronze
1

Die Skill-ZIP herunterladen

2

In Claude hochladen

Gehe zu Einstellungen → Fähigkeiten → Skills → Skill hochladen

3

Einschalten und loslegen

Teste es

Verwendung von "azure-eventhub-java". Create an EventHubProducerClient with DefaultAzureCredential

Erwartetes Ergebnis:

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

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

Erwartetes Ergebnis:

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

Sicherheitsaudit

Sicher
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
Gescannte Dateien
362
Analysierte Zeilen
0
befunde
1
Gesamtzahl Audits
Keine Sicherheitsprobleme gefunden
Auditiert von: claude

Qualitätsbewertung

38
Architektur
100
Wartbarkeit
85
Inhalt
31
Community
100
Sicherheit
100
Spezifikationskonformität

Was du bauen kannst

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

Probiere diese 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

Bewährte Verfahren

  • 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

Vermeiden

  • 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

Häufig gestellte Fragen

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.

Entwicklerdetails

Autor

sickn33

Lizenz

MIT

Repository

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

Ref

main

Dateistruktur

đź“„ SKILL.md