المهارات azure-eventhub-java
📦

azure-eventhub-java

آمن

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.

يدعم: Claude Codex Code(CC)
🥉 75 برونزي
1

تنزيل ZIP المهارة

2

رفع في Claude

اذهب إلى Settings → Capabilities → Skills → Upload skill

3

فعّل وابدأ الاستخدام

اختبرها

استخدام "azure-eventhub-java". Create an EventHubProducerClient with DefaultAzureCredential

النتيجة المتوقعة:

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

استخدام "azure-eventhub-java". Send events in batch with partition key

النتيجة المتوقعة:

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

التدقيق الأمني

آمن
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
الملفات التي تم فحصها
362
الأسطر التي تم تحليلها
0
النتائج
1
إجمالي عمليات التدقيق
لا توجد مشكلات أمنية
تم تدقيقه بواسطة: claude

درجة الجودة

38
الهندسة المعمارية
100
قابلية الصيانة
85
المحتوى
50
المجتمع
100
الأمان
100
الامتثال للمواصفات

ماذا يمكنك بناءه

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

جرّب هذه الموجهات

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

أفضل الممارسات

  • 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

تجنب

  • 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

الأسئلة المتكررة

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.

تفاصيل المطور

المؤلف

sickn33

الترخيص

MIT

المستودع

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

مرجع

main

بنية الملفات

📄 SKILL.md