SuperAPI AI 工具集

azure-eventhub-java

数据与分析

查看项目

更新于 10-16 01:27

技能介绍

用途:使用 Azure Event Hubs SDK for Java 构建实时流式应用,适用于事件流处理、高吞吐数据写入等场景。

依赖:通过 Maven 引入 com.azure:azure-messaging-eventhubs,版本 5.19.0。

客户端:可用连接字符串、完整连接字符串(含 EntityPath)或 DefaultAzureCredential 创建 EventHubProducerClient 与 EventHubConsumerClient,也提供异步生产者/消费者客户端;消费者需指定 consumerGroup,默认使用 DEFAULT_CONSUMER_GROUP_NAME 或 "$Default"。

主要能力:发送单条或批量事件(EventDataBatch,批满后可 send 并新建批次);按分区 ID 或分区键发送,分区键可用于保证同一分区内顺序;为事件附加属性;从指定分区接收事件(receiveFromPartition,可设 maxEvents、起始位置与超时);使用 EventPosition 指定 earliest、latest、offset、sequence number 或入队时间起点;获取 Event Hub 与分区属性;异步订阅接收。生产环境推荐 EventProcessorClient,配合 BlobCheckpointStore 实现负载均衡与检查点,支持单事件或批量(maxBatchSize)处理及错误回调。

用法要点:处理完成后调用 updateCheckpoint;在 processError 中区分瞬时错误;客户端使用后必须 close,可用 try-with-resources。连接信息可通过环境变量 EVENT_HUBS_CONNECTION_STRING、EVENT_HUBS_NAME、STORAGE_CONNECTION_STRING 提供。

限制:仅在任务明确匹配上述范围时使用;输出不能替代针对具体环境的验证、测试或专家评审;若缺少必要输入、权限、安全边界或成功标准,应停止并请求澄清。其他细节暂未提供。