azure-eventhub-java
Azure Event Hubs Java SDK
Azure Event Hubs SDK for Java を使用してリアルタイムストリーミングアプリケーションを構築します。イベントストリーミング、高スループットデータ収集、イベント駆動アーキテクチャに最適です。
下载技能 ZIP
在 Claude 中上传
前往 设置 → 功能 → 技能 → 上传技能
开启并开始使用
测试它
正在使用“azure-eventhub-java”。 DefaultAzureCredential を使用して EventHubProducerClient を作成する
预期结果:
EventHubProducerClient producer = new EventHubClientBuilder()
.fullyQualifiedNamespace("<namespace>.servicebus.windows.net")
.eventHubName("<event-hub-name>")
.credential(new DefaultAzureCredentialBuilder().build())
.buildProducerClient();
正在使用“azure-eventhub-java”。 パーティションキーを使用してバッチでイベントを送信する
预期结果:
CreateBatchOptions options = new CreateBatchOptions()
.setPartitionKey("customer-123");
EventDataBatch batch = producer.createBatch(options);
batch.tryAdd(new EventData("Customer event"));
producer.send(batch);
安全审计
安全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.
质量评分
你能构建什么
イベントストリーミングパイプラインの構築
システム間のリアルタイムデータストリーミングのためのイベントプロデューサーとコンシューマーを作成する
高スループットデータ収集の実装
バッチ処理とパーティション戦略を使用して毎秒数百万のイベントを処理する
スケーラブルなマイクロサービス通信の作成
マイクロサービスのイベント駆動通信のメッセージ基盤として Event Hubs を使用する
试试这些提示
Java で接続文字列を使用して EventHubProducerClient を作成する方法を示してください
特定のパーティションからイベントを受信するための EventHubConsumerClient を作成するにはどうすればよいですか？
本番規模の処理のために BlobCheckpointStore を使用した EventProcessorClient を実装してください
ノンブロッキングイベント送信のために EventHubProducerAsyncClient を使用する方法を示してください
最佳实践
- 自動ロードバランシングとチェックポイント機能を備えた EventProcessorClient を本番ワークロードに使用する
- 効率的なネットワーク利用のために EventDataBatch を使用してイベントをバッチ処理する
- 適切なクリーンアップを確保するために try-with-resources を使用してクライアントをクローズする
避免
- 接続文字列をソースコードにハードコードしないでください - 環境変数または Azure Key Vault を使用する
- イベントを 1 つずつ送信しないでください - スループットのためにバッチ処理を使用する
- チェックポイントをスキップしないでください - 再起動時にイベントの再処理につながります