71장. KafkaConnectSpec schema reference
사용 위치: KafkaConnect
KafkaConnectSpec 스키마 속성의 전체 목록
Kafka Connect 클러스터를 구성합니다.
71.1. config 링크 복사링크가 클립보드에 복사되었습니다!
구성 속성을 사용하여 Kafka Connect 옵션을 키로 구성합니다.
값은 다음 JSON 유형 중 하나일 수 있습니다.
- 문자열
- 숫자
- 부울
특정 옵션에는 기본값이 있습니다.
-
기본 값이
connect-cluster인group.id -
offset.storage.topic및 기본값connect-cluster-offsets -
config.storage.topics의 기본값connect-cluster-configs -
status.storage.topic(기본값:connect-cluster-status) -
기본 값이
org.apache.kafka.connect.json.JsonConverter인key.converter -
value.converter기본값org.apache.kafka.connect.json.JsonConverter
이러한 옵션은 KafkaConnect.spec.config 속성에 없는 경우 자동으로 구성됩니다.
예외
Apache Kafka 설명서에 나열된 옵션을 지정하고 구성할 수 있습니다.
그러나 Apache Kafka용 Streams는 다음과 관련된 옵션을 구성하고 관리하는 작업을 수행합니다. 이 옵션은 변경할 수 없습니다.
- Kafka 클러스터 부트스트랩 주소
- 보안(암호화, 인증 및 권한 부여)
- 리스너 및 REST 인터페이스 구성
- 플러그인 경로 구성
다음 접두사가 있는 속성은 설정할 수 없습니다.
-
bootstrap.servers -
consumer.interceptor.classes -
리스너. -
plugin.path -
producer.interceptor.classes -
rest. -
SASL. -
보안. -
ssl.
config 속성에 변경할 수 없는 옵션이 포함되어 있으면 무시되고 경고 메시지가 Cluster Operator 로그 파일에 기록됩니다. 지원되는 모든 옵션은 Apache Kafka에 대해 Streams에서 구성한 옵션에 대한 다음 예외를 포함하여 Kafka Connect로 전달됩니다.
-
지원되는 TLS 버전 및 암호화 제품군에대한 모든
ssl구성
Kafka Connect 구성 예
Cluster Operator는 제공된 config 오브젝트의 키 또는 값을 확인하지 않습니다. 잘못된 구성이 제공되면 Kafka Connect 클러스터가 시작되지 않거나 불안정해질 수 있습니다. 이 경우 Cluster Operator가 모든 Kafka Connect 노드에 새 구성을 롤아웃할 수 있도록 구성을 수정합니다.