GetAzureEventHub 2025.5.31.15¶
번들¶
org.apache.nifi | nifi-azure-nar
설명¶
안정적인 체크포인트 추적 없이 Microsoft Azure Event Hubs에서 메시지를 수신합니다. 클러스터링 환경에서는 GetAzureEventHub 프로세서 인스턴스가 독립적으로 작동하며 모든 클러스터 노드가 모든 메시지를 처리합니다(기본 전용 모드로 프로세서를 실행하는 경우 제외). ConsumeAzureEventHub 는 Azure Event Hubs에서 메시지를 수신하는 권장 방법을 제공합니다. 이 프로세서는 Azure Event Hubs에 연결하기 위한 스레드 풀을 생성합니다.
입력 요구 사항¶
FORBIDDEN
민감한 동적 속성 지원¶
false
속성¶
속성 |
설명 |
|---|---|
이벤트 허브 컨슈머 그룹 |
이벤트를 가져올 때 사용할 컨슈머 그룹의 이름입니다 |
이벤트 허브 메시지 대기열 시간 |
YYYY-MM-DDThhmmss.sssZ (2016-01-01T01:01:01.000Z) 형식의 타임스탬프(ISO-8601 인스턴트)로, 이벤트 허브에서 메시지를 대기열에 추가하여 읽기를 시작해야 합니다 |
Event Hub Name |
Azure Event Hubs의 소스 이름 |
이벤트 허브 네임스페이스 |
서비스 버스 엔드포인트 도메인에 접두사가 붙은 Azure Event Hubs의 네임스페이스 |
파티션 수신기 시간 제한(밀리초) |
파티션 수신기가 반환하기 전에 Fetch Size를 수신할 때까지 대기해야 하는 시간(밀리초)입니다. 기본값은 60000입니다 |
파티션 리시버 가져오기 크기 |
수신자가 반환하기 전에 이벤트 허브 파티션에서 가져와야 하는 이벤트의 수입니다. 기본값은 100입니다 |
서비스 버스 엔드포인트 |
기본 windows.net 도메인에 없는 네임스페이스를 지원합니다. |
공유 액세스 정책 이름 |
공유 액세스 정책의 이름입니다. 이 정책에는 Listen 클레임이 있어야 합니다. |
공유 액세스 정책 기본 키 |
공유 액세스 정책의 키입니다. 기본 키 또는 보조 키 중 하나를 사용할 수 있습니다. |
전송 유형 |
Azure Event Hubs와의 통신을 위한 고급 메시지 큐 프로토콜 전송 유형 |
프록시 구성 서비스 |
네트워크 요청을 프록시할 프록시 구성 컨트롤러 서비스를 지정합니다. |
use-managed-identity |
Azure VM/VMSS 의 관리형 ID를 사용할지 여부를 선택합니다 |
관계¶
이름 |
설명 |
|---|---|
성공 |
이벤트 허브에서 성공적으로 수신된 모든 FlowFile 은 이 관계로 전송됩니다. |
Writes 특성¶
이름 |
설명 |
|---|---|
eventhub.enqueued.timestamp |
이벤트 허브에 메시지가 큐에 추가된 시간(epoch 이후 밀리초, UTC)입니다 |
eventhub.offset |
메시지가 저장된 파티션에 대한 오프셋입니다 |
eventhub.sequence |
메시지와 연결된 Azure 시퀀스 번호입니다 |
eventhub.name |
메시지를 가져온 이벤트 허브의 이름입니다 |
eventhub.partition |
메시지를 가져온 이벤트 허브 파티션의 이름입니다 |
eventhub.property.* |
이 메시지의 애플리케이션 속성입니다. IE: ‘applicatio’은 ‘eventhub.property.application’입니다 |