44장. Kafka Sink
데이터를 Kafka 주제로 보냅니다.
Kamelet은 설정할 다음 헤더를 이해할 수 있습니다.
-
key
/ce-key
: as message key -
partition-key
/ce-partitionkey
: as message partition key
두 헤더 모두 선택 사항입니다.
44.1. 구성 옵션 링크 복사링크가 클립보드에 복사되었습니다!
다음 표에는 kafka-sink
Kamelet에 사용할 수 있는 구성 옵션이 요약되어 있습니다.
속성 | 이름 | 설명 | 유형 | Default | 예제 |
---|---|---|---|---|---|
bootstrapServers * | 브로커 | Kafka 브로커 URL의 쉼표로 구분된 목록 | string | ||
password * | 암호 | kafka로 인증할 암호 | string | ||
topic * | 주제 이름 | Kafka 주제 이름의 쉼표로 구분된 목록 | string | ||
사용자 * | 사용자 이름 | Kafka에 인증할 사용자 이름 | string | ||
saslMechanism | SASL 메커니즘 | SASL(Simple Authentication and Security Layer) 메커니즘이 사용되었습니다. | string |
| |
securityProtocol | 보안 프로토콜 | 브로커와 통신하는 데 사용되는 프로토콜입니다. SASL_PLAINTEXT, PLAINTEXT, SASL_SSL 및 SSL이 지원됩니다. | string |
|
별표(*)로 표시된 필드는 필수 항목입니다.