GetAzureEventHub

文档中心 › 组件索引 › GetAzureEventHub

GetAzureEventHub Processor

类型全限定名：cn.org.acal.lynxus.processors.azure.eventhub.GetAzureEventHub

所属 Bundle：cn.org.acal.lynxus:lynxus-azure-nar:2.11.8

已废弃： 该组件已废弃，未来可能被移除。
建议改用：cn.org.acal.lynxus.processors.azure.eventhub.ConsumeAzureEventHub

描述

从 Microsoft Azure Event Hubs 接收消息，不进行可靠的检查点跟踪。在集群环境中，

标签

azuremicrosoftcloudeventhubeventsstreamingstreams

属性

下表中，加粗的属性为必填项；其余为可选项。表格同时标注默认值、是否支持表达式语言，以及是否为敏感属性（值会被加密）。

名称默认值可选值描述
Event Hub Namespace以服务总线终结点域为前缀的 Azure 事件中心的Namespace
Event Hub NameAzure 事件中心源的名称
Service Bus Endpoint.servicebus.windows.net
  • Azure — 通用 Service Bus 端点
  • Azure 中国 — 中国 Service Bus 端点
  • Azure 德国 — 德国 Service Bus 端点
  • Azure 美国政府 — 美国政府 Service Bus 端点
支持不在默认 windows.net 域中的Namespace。
Transport TypeAmqp
  • AMQP — 通过 TCP 在端口 5671 和 5672 上使用 AMQP
  • AMQP_WEB_SOCKETS — 通过 HTTPS 使用 WebSockets 在端口 443 上使用 AMQP
用于与 Azure 事件中心通信的高级消息队列协议传输类型
Shared Access Policy Name共享访问策略的名称。 该保单必须包含 Listen 声明。
Shared Access Policy Key共享访问策略的关键。 可以使用主键或辅助键。
敏感属性：是
Authentication StrategyMANAGED_IDENTITY
  • Managed Identity — 使用承载它的 Azure 资源的托管标识（Managed Identity）进行身份验证。
  • Shared Access Signature — 使用共享访问策略（Shared Access Policy）名称和密钥进行身份验证。
  • OAuth2 — 使用由 Entra 注册应用程序支持的 OAuth2 访问令牌提供程序（Access Token Provider）进行身份验证。
  • Identity Federation — 使用与 Azure AD 访问令牌交换的工作负载身份令牌进行身份验证。
指定用于向 Azure 事件中心进行身份验证的策略
Event Hubs Access Token Provider控制器服务 API：
OAuth2AccessTokenProvider
cn.org.acal.lynxus-lynxus-standard-services-api-nar-2.11.8		Controller Service提供 OAuth2 访问令牌以对 Azure 事件中心进行身份验证
Event Hubs Identity Federation Token Provider控制器服务 API：
AzureIdentityFederationTokenProvider
cn.org.acal.lynxus-lynxus-azure-services-api-nar-2.11.8		在向 Azure 事件中心进行身份验证时，Controller Service将工作负载身份令牌交换为 Azure AD 访问令牌。
Consumer Group$Default拉取事件时使用的消费者组的名称
Message Enqueue Time格式为 YYYY-MM-DDThhmmss.sssZ（2016-01-01T01:01:01.000Z）的时间戳（ISO-8601 时刻），从该时间戳起消息应已入队到事件中心以开始读取
分区接收器获取大小接收器在返回之前应从事件中心分区获取的事件数。默认为 100
分区接收器超时分区接收器等待接收获取大小的时间（毫秒）。默认为 60000
Proxy Configuration Service控制器服务 API：
ProxyConfigurationService
cn.org.acal.lynxus-lynxus-standard-services-api-nar-2.11.8		指定代理配置 Controller Service 来代理网络请求。

关系 (Relationships)

名称描述自动终止
success从事件中心成功接收到的任何 FlowFile 都将传输到此关系。否

写入的 FlowFile 属性

名称描述
eventhub.enqueued.timestamp消息在事件中心排队的时间（自纪元以来的毫秒数，UTC）
eventhub.offset存储消息的分区的偏移量
eventhub.sequence与消息关联的 Azure 序列号
eventhub.name从中提取消息的事件中心的名称
eventhub.partition从中提取消息的事件中心分区的名称
eventhub.property.*此消息的应用程序属性。 IE：“应用程序”将是“eventhub.property.application”

状态管理

该组件不存储状态。

受限 (Restricted)

该组件不受限。

输入要求

该组件不允许有传入连接。

另请参阅

© 2026 ACAL Organization. Licensed under Apache License 2.0.