Kafka3ConnectionService¶
설명¶
공급자 또는 컨슈머 작업을 위해 Kafka Broker에 대한 연결을 제공하고 관리합니다.
속성¶
아래 목록에서 필수 속성에는 별표(*)가 표시되어 있습니다. 다른 속성은 선택 사항으로 간주됩니다. 이 테이블에는 기본값과 속성이 NiFi 식 언어를 지원하는지 여부도 표시됩니다.
표시 이름 |
API 이름 |
기본값 |
허용되는 값 |
설명 |
|---|---|---|---|---|
SSL 컨텍스트 서비스 |
SSL 컨텍스트 서비스 |
Kafka 브로커와의 SSL 통신을 지원하는 서비스 |
||
Acknowledgment Wait Time * |
ack.wait.time |
5초 |
Kafka에 메시지를 보낸 후 서비스가 Kafka의 응답을 기다리는 시간을 나타내며, 이 기간 내에 Kafka가 메시지를 확인하지 않으면 서비스에서 예외를 throw합니다. |
|
Bootstrap Servers * |
bootstrap.servers |
호스트:포트 형식의 쉼표로 구분된 Kafka 부트스트랩 서버 목록입니다. kafka bootstrap.servers 속성에 해당합니다 |
||
Client Timeout * |
default.api.timeout.ms |
60초 |
Kafka 클라이언트 작업에 대한 기본 시간 제한입니다. Kafka default.api.timeout.ms에 매핑됩니다. Kafka request.timeout.ms 속성은 구성된 시간 제한의 절반에서 파생됩니다 |
|
Transaction Isolation Level * |
isolation.level |
read_committed |
|
서비스가 Kafka와 통신할 때 트랜잭션 격리 수준을 처리하는 방법을 지정합니다. 커밋되지 않음 옵션은 메시지가 Kafka에 쓰여지는 즉시 수신되지만, 생성자가 트랜잭션을 취소하는 경우에도 메시지를 끌어온다는 의미입니다. 커밋된 옵션은 생성자의 트랜잭션이 취소된 메시지를 수신하지 않도록 서비스를 구성하지만, 컨슈머는 메시지가 사용 가능해지면 풀링하는 대신 생성자가 전체 트랜잭션을 완료할 때까지 기다려야 하므로 약간의 지연 시간이 발생할 수 있습니다. Kafka isolation.level 속성에 해당합니다. |
Max Metadata Wait Time * |
max.block.ms |
5초 |
게시자가 메타데이터를 얻기 위해 기다리거나 ‘보내기’ 호출 중에 버퍼가 플러시될 때까지 기다린 후 전체 ‘보내기’ 호출이 실패할 때까지 기다리는 시간입니다. Kafka max.block.ms 속성에 해당합니다 |
|
Max Poll Records * |
max.poll.records |
10000 |
단일 폴링에서 Kafka가 반환해야 하는 최대 레코드 수입니다. |
|
SASL Mechanism * |
sasl.mechanism |
GSSAPI |
|
SASL 인증에 사용되는 메커니즘입니다. Kafka 클라이언트 sasl.mechanism 속성에 해당합니다 |
SASL Password * |
sasl.password |
PLAIN 또는 SCRAM SASL 메커니즘을 사용할 때 구성된 사용자 이름과 함께 제공되는 비밀번호 |
||
SASL Username * |
sasl.username |
PLAIN 또는 SCRAM SASL 사용 시 구성된 비밀번호와 함께 제공된 사용자 이름 메커니즘 |
||
Security Protocol * |
security.protocol |
PLAINTEXT |
|
브로커와 통신하는 데 사용되는 보안 프로토콜입니다. Kafka 클라이언트 security.protocol 속성에 해당합니다 |
상태 관리¶
이 구성 요소는 상태를 저장하지 않습니다.
제한됨¶
이 구성 요소는 제한되지 않습니다.
시스템 리소스 고려 사항¶
이 구성 요소는 시스템 리소스 고려 사항을 지정하지 않습니다.