Compétences azure-eventhub-java
📦

azure-eventhub-java

Sûr

Azure Event Hubs Java SDK

Azure Event Hubs SDK for Java を使用してリアルタイムストリーミングアプリケーションを構築します。イベントストリーミング、高スループットデータ収集、イベント駆動アーキテクチャに最適です。

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". DefaultAzureCredential を使用して EventHubProducerClient を作成する

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". パーティションキーを使用してバッチでイベントを送信する

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

イベントストリーミングパイプラインの構築

システム間のリアルタイムデータストリーミングのためのイベントプロデューサーとコンシューマーを作成する

高スループットデータ収集の実装

バッチ処理とパーティション戦略を使用して毎秒数百万のイベントを処理する

スケーラブルなマイクロサービス通信の作成

マイクロサービスのイベント駆動通信のメッセージ基盤として Event Hubs を使用する

Essayez ces prompts

基本のイベントプロデューサー 
Java で接続文字列を使用して EventHubProducerClient を作成する方法を示してください
イベントコンシューマーの設定 
特定のパーティションからイベントを受信するための EventHubConsumerClient を作成するにはどうすればよいですか？
本番用イベントプロセッサー 
本番規模の処理のために BlobCheckpointStore を使用した EventProcessorClient を実装してください
非同期イベント処理 
ノンブロッキングイベント送信のために EventHubProducerAsyncClient を使用する方法を示してください

Bonnes pratiques

  • 自動ロードバランシングとチェックポイント機能を備えた EventProcessorClient を本番ワークロードに使用する
  • 効率的なネットワーク利用のために EventDataBatch を使用してイベントをバッチ処理する
  • 適切なクリーンアップを確保するために try-with-resources を使用してクライアントをクローズする

Éviter

  • 接続文字列をソースコードにハードコードしないでください - 環境変数または Azure Key Vault を使用する
  • イベントを 1 つずつ送信しないでください - スループットのためにバッチ処理を使用する
  • チェックポイントをスキップしないでください - 再起動時にイベントの再処理につながります

Foire aux questions

EventHubProducerClient と EventHubProducerAsyncClient の違いは何ですか？
EventHubProducerClient は同期であり、操作が完了するまでブロックします。EventHubProducerAsyncClient はノンブロッキングで、リアクティブプログラミングパターンのために Mono/Flux を返します。
パーティション戦略をどのように選択すればよいですか？
特定のカテゴリ（顧客 ID など）内での順序保持のためにパーティションキーを使用します。順序が重要でない場合は、Azure にパーティションを割り当せて均等分散させます。
チェックポイントとは何ですか？また、なぜ重要なのですか？
チェックポイントは処理済みイベントのポジションを Azure Blob Storage に保存します。これにより、プロセッサーは再起動や障害後に中断した場所から再開できます。
一時的なエラーをどのように処理すればよいですか？
processError コールバックを使用して AmqpException エラーをキャッチします。isTransient() をチェックして、自動的に再試行されるエラーを識別します。
接続文字列の代わりにマネージド ID を使用できますか？
はい、DefaultAzureCredentialBuilder を使用して Azure Active Directory マネージド ID で認証できます。これは本番環境に推奨されます。
earliest と latest のイベントポジションの違いは何ですか？
earliest() はパーティション内の最初の利用可能なイベントから開始します。latest() はコンシューマー接続後に到着する新しいイベントのみから開始します。

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