Red Hat Summit Red Hat Summit지원콘솔개발자평가판 시작연락처

69장. KafkaConnectSpec schema reference

사용 위치: KafkaConnect

KafkaConnectSpec 스키마 속성의 전체 목록

Kafka Connect 클러스터를 구성합니다.

69.1. config
링크 복사

구성 속성을 사용하여 Kafka Connect 옵션을 키로 구성합니다.

값은 다음 JSON 유형 중 하나일 수 있습니다.

  • 문자열
  • 숫자
  • 부울

특정 옵션에는 기본값이 있습니다.

  • 기본 값이 connect-cluster인 group.id
  • offset.storage.topic 및 기본값 connect-cluster-offsets
  • config.storage.topic s의 기본값 connect-cluster-configs
  • status.storage.topic (기본값: connect-cluster-status)
  • key.converter with default value org.apache.kafka.connect.json.JsonConverter
  • value.converter with default value org.apache.kafka.connect.json.JsonConverter

이러한 옵션은 KafkaConnect.spec.config 속성에 없는 경우 자동으로 구성됩니다.

예외

Apache Kafka 설명서에 나열된 옵션을 지정하고 구성할 수 있습니다.

그러나 AMQ Streams는 다음과 관련된 옵션을 구성하고 관리합니다. 이 옵션은 변경할 수 없습니다.

  • Kafka 클러스터 부트스트랩 주소
  • 보안(암호화, 인증 및 권한 부여)
  • 리스너 및 REST 인터페이스 구성
  • 플러그인 경로 구성

다음 접두사가 있는 속성은 설정할 수 없습니다.

  • bootstrap.servers
  • consumer.interceptor.classes
  • 리스너.
  • plugin.path
  • producer.interceptor.classes
  • rest.
  • SASL.
  • 보안.
  • ssl.

config 속성에 변경할 수 없는 옵션이 포함되어 있으면 무시되고 경고 메시지가 Cluster Operator 로그 파일에 기록됩니다. 지원되는 모든 옵션은 AMQ Streams에서 구성한 옵션에 대한 다음 예외를 포함하여 Kafka Connect로 전달됩니다.

Kafka Connect 구성 예

apiVersion: kafka.strimzi.io/v1beta2
kind: KafkaConnect
metadata:
  name: my-connect
spec:
  # ...
  config:
    group.id: my-connect-cluster
    offset.storage.topic: my-connect-cluster-offsets
    config.storage.topic: my-connect-cluster-configs
    status.storage.topic: my-connect-cluster-status
    key.converter: org.apache.kafka.connect.json.JsonConverter
    value.converter: org.apache.kafka.connect.json.JsonConverter
    key.converter.schemas.enable: true
    value.converter.schemas.enable: true
    config.storage.replication.factor: 3
    offset.storage.replication.factor: 3
    status.storage.replication.factor: 3
  # ...
Copy to Clipboard Toggle word wrap

중요

Cluster Operator는 제공된 config 오브젝트의 키 또는 값을 확인하지 않습니다. 잘못된 구성이 제공되면 Kafka Connect 클러스터가 시작되지 않거나 불안정해질 수 있습니다. 이 경우 Cluster Operator가 모든 Kafka Connect 노드에 새 구성을 롤아웃할 수 있도록 구성을 수정합니다.

맨 위로 이동
Red Hat logoGithubredditYoutubeTwitter

자세한 정보

평가판, 구매 및 판매

커뮤니티

Red Hat 문서 정보

Red Hat을 사용하는 고객은 신뢰할 수 있는 콘텐츠가 포함된 제품과 서비스를 통해 혁신하고 목표를 달성할 수 있습니다. 최신 업데이트를 확인하세요.

보다 포괄적 수용을 위한 오픈 소스 용어 교체

Red Hat은 코드, 문서, 웹 속성에서 문제가 있는 언어를 교체하기 위해 최선을 다하고 있습니다. 자세한 내용은 다음을 참조하세요.Red Hat 블로그.

Red Hat 소개

Red Hat은 기업이 핵심 데이터 센터에서 네트워크 에지에 이르기까지 플랫폼과 환경 전반에서 더 쉽게 작업할 수 있도록 강화된 솔루션을 제공합니다.

Theme

© 2025 Red Hat