45장. Kafka Source

topic *

주제 이름

Kafka 주제 이름의 쉼표로 구분된 목록

string

bootstrapServers *

브로커

Kafka 브로커 URL의 쉼표로 구분된 목록

string

securityProtocol

보안 프로토콜

브로커와 통신하는 데 사용되는 프로토콜입니다. SASL_PLAINTEXT, PLAINTEXT, SASL_SSL 및 SSL이 지원됩니다.

string

"SASL_SSL"

saslMechanism

SASL 메커니즘

SASL(Simple Authentication and Security Layer) 메커니즘이 사용되었습니다.

string

"PLAIN"

사용자 *

사용자 이름

Kafka에 인증할 사용자 이름

string

password *

암호

kafka로 인증할 암호

string

autoCommitEnable

자동 커밋 활성화

true인 경우 사용자가 이미 가져온 메시지 오프셋을 ZooKeeper에 주기적으로 커밋합니다.

boolean

true

allowManualCommit

수동 커밋 허용

수동 커밋 허용 여부

boolean

false

autoOffsetReset

자동 Offset Reset

초기 오프셋이 없을 때 수행할 작업. 3개의 10.0.0.1이 있으며 값은 최신, 가장 빠른, none 중 하나가 될 수 있습니다.

string

"latest"

pollOnError

오류 발생 시 폴링

kafka가 새 메시지를 폴링하는 동안 예외를 제한하면 어떻게 해야 합니까. 5개의 10.0.0.1이 있으며 값은 DISCARD, ERROR_HANDLER, RECONNECT, RETRY, STOP 중 하나가 될 수 있습니다.

string

"ERROR_HANDLER"

deserializeHeaders

헤더 자동 삭제

이 기능을 사용하면 Kamelet 소스가 모든 메시지 헤더를 String 표현으로 역직렬화합니다. 기본값은 false입니다.

boolean

true

consumerGroup

소비자 그룹

이 소스가 속한 소비자 그룹을 고유하게 식별하는 문자열입니다.

string

"my-group-id"