Kafka3ConnectionService

Kafka3ConnectionService (Kafka3 연결 서비스)

프로듀서 또는 컨슈머 작업을 위해 Kafka 브로커에 대한 연결을 제공하고 관리하는 서비스예요.

출처: 문서

본문

설명

프로듀서 또는 컨슈머 작업을 위해 Kafka 브로커에 대한 연결을 제공하고 관리해요.

태그

kafka, openflow

속성 (Properties)

아래 목록에서 필수 속성은 별표(*)로 표시했어요. 그 외 속성은 선택 사항이고, 표에는 기본값과 NiFi Expression Language 지원 여부도 함께 나와 있어요.

표시 이름 API 이름 기본값 허용 값 설명
SSL Context Service SSL Context Service Kafka 브로커와의 SSL 통신을 지원하는 서비스예요.
Acknowledgment Wait Time * ack.wait.time 5 sec 메시지를 Kafka로 보낸 후 서비스가 Kafka의 응답을 기다리는 시간을 나타내요. 이 시간 내에 Kafka가 메시지를 확인(acknowledge)하지 않으면 서비스는 예외를 던져요.
Bootstrap Servers * bootstrap.servers host:port 형식의 Kafka Bootstrap Servers 쉼표로 구분된 목록이에요. Kafka의 bootstrap.servers 속성에 대응해요.
Client Timeout * default.api.timeout.ms 60 sec Kafka 클라이언트 작업의 기본 타임아웃이에요. Kafka의 default.api.timeout.ms에 매핑돼요. Kafka의 request.timeout.ms 속성은 설정된 타임아웃의 절반에서 파생돼요.
Transaction Isolation Level * isolation.level read_committed Read Committed, Read Uncommitted Kafka와 통신할 때 트랜잭션 격리 수준을 처리하는 방식을 지정해요. uncommitted 옵션은 메시지가 Kafka에 쓰여지는 즉시 수신되며, 프로듀서가 트랜잭션을 취소해도 가져온다는 뜻이에요. committed 옵션은 프로듀서의 트랜잭션이 취소된 메시지를 수신하지 않도록 설정하지만, 컨슈머가 메시지가 사용 가능해질 때 가져오는 대신 프로듀서가 전체 트랜잭션을 끝낼 때까지 기다려야 하므로 약간의 지연이 발생할 수 있어요. Kafka의 isolation.level 속성에 대응해요.
Max Metadata Wait Time * max.block.ms 5 sec 'send' 호출 중에 퍼블리셔가 메타데이터를 얻거나 버퍼가 플러시되기를 기다리는 시간이에요. 이 시간을 초과하면 전체 'send' 호출이 실패해요. Kafka의 max.block.ms 속성에 대응해요.
Max Poll Records * max.poll.records 10000 Kafka가 단일 poll에서 반환해야 하는 최대 레코드 수예요.
SASL Mechanism * sasl.mechanism GSSAPI GSSAPI, PLAIN, SCRAM-SHA-256, SCRAM-SHA-512 인증에 사용하는 SASL 메커니즘이에요. Kafka Client의 sasl.mechanism 속성에 대응해요.
SASL Password * sasl.password PLAIN 또는 SCRAM SASL 메커니즘을 사용할 때 설정된 사용자 이름과 함께 제공되는 비밀번호예요.
SASL Username * sasl.username PLAIN 또는 SCRAM SASL 메커니즘을 사용할 때 설정된 비밀번호와 함께 제공되는 사용자 이름이에요.
Security Protocol * security.protocol PLAINTEXT PLAINTEXT, SSL, SASL_PLAINTEXT, SASL_SSL 브로커와 통신하는 데 사용하는 보안 프로토콜이에요. Kafka Client의 security.protocol 속성에 대응해요.

상태 관리

이 컴포넌트는 상태를 저장하지 않아요.

제한 사항 (Restricted)

이 컴포넌트는 제한되지 않아요.

시스템 리소스 고려 사항

이 컴포넌트는 시스템 리소스 고려 사항을 지정하지 않아요.

더 알아보기 (Learn more)