LogoClawIndex
案例技能关于
LogoClawIndex

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 及以上

来源

  • 规范: SKILL.md

ClawIndex

OpenClaw Skills 与 Use Case 索引

ClawIndex 是一个生态驱动的 OpenClaw Skills 与真实 Use Case 索引站。

索引

Skills·
Cases

Meta

关于·
声明·
邮箱·
GitHub
© 2026 ClawIndex 保留所有权利。
azure
event-hubs
java
流处理
事件驱动
消息中间件
实时
数据接入
创建事件中心生产者客户端
创建事件中心消费者客户端
发送单个事件
发送事件批次
Azure Event Hubs 连接字符串
事件中心名称
用于检查点的 Azure Storage 连接字符串
发送至事件中心的事件
从事件中心分区接收的事件
存储在 Blob 中的检查点