azure-eventhub-java - 使用 Azure Event Hubs Java SDK 构建实时流应用
Azure Event Hubs 的 Java SDK,支持事件发送、消费、批量处理和基于分区的事件流处理。
标签
更新于: 2026-06-30能力
典型输入
典型输出
该技能可以做什么
- 创建事件中心生产者客户端
- 创建事件中心消费者客户端
- 发送单个事件
- 发送事件批次
- 发送至指定分区
- 按分区键发送事件
- 从分区接收事件
- 创建事件处理器客户端
- 批量处理事件
- 获取事件中心属性
- 获取分区属性
- 关闭客户端资源
输入
- Azure Event Hubs 连接字符串
- 事件中心名称
- 用于检查点的 Azure Storage 连接字符串
- Azure 凭据(DefaultAzureCredential)
- 消费者组名称
- 分区 ID 或分区键
输出
- 发送至事件中心的事件
- 从事件中心分区接收的事件
- 存储在 Blob 中的检查点
- 事件中心属性信息
- 分区属性信息
要求
- Java 运行环境
- Maven 或 Gradle 构建工具
- Azure Event Hubs 命名空间
- Azure 存储账户(用于检查点)
- azure-messaging-eventhubs SDK 5.19.0 及以上
- azure-messaging-eventhubs-checkpointstore-blob SDK 1.20.0 及以上
