6장. Kafka Connect 구성 속성

type: string
가져오기: high

커넥터 구성이 저장되는 Kafka 항목의 이름입니다.

type: string
가져오기: high

이 작업자가 속하는 Connect 클러스터 그룹을 식별하는 고유한 문자열입니다.

유형: class
중요도: high

Kafka에 기록된 Kafka Connect 형식과 직렬화된 형식을 변환하는 데 사용되는 클래스입니다. 이렇게 하면 Kafka에 기록되거나 읽은 메시지의 키 형식을 제어할 수 있으며 커넥터가 모든 직렬화 형식으로 작동할 수 있습니다. 일반적인 형식의 예로는 JSON 및 Avro가 있습니다.

type: string
가져오기: high

소스 커넥터 오프셋이 저장되는 Kafka 항목의 이름입니다.

type: string
가져오기: high

커넥터 및 작업 상태가 저장되는 Kafka 항목의 이름입니다.

유형: class
중요도: high

Kafka에 기록된 Kafka Connect 형식과 직렬화된 형식을 변환하는 데 사용되는 클래스입니다. 이렇게 하면 Kafka에 기록되거나 읽은 메시지의 값 형식을 제어하고, 커넥터가 모든 직렬화 형식으로 작동할 수 있도록 커넥터와 독립적이므로 이 작업을 수행할 수 있습니다. 일반적인 형식의 예로는 JSON 및 Avro가 있습니다.

type: list
Default: localhost:9092
가져오기: 높음

Kafka 클러스터에 대한 초기 연결을 설정하는 데 사용할 호스트/포트 쌍 목록입니다. 클라이언트는 부트 스트랩을 위해 여기에 지정된 서버에 관계없이 모든 서버를 사용합니다. 이 목록은 전체 서버 세트를 검색하는 데 사용된 초기 호스트에만 영향을 미칩니다. 이 목록은 host1:port1,host2:port2,…​ 형식이어야 합니다. 이러한 서버는 초기 연결이 전체 클러스터 멤버십을 검색하는 데만 사용되므로(이는 동적으로 변경될 수 있음) 전체 서버 세트를 포함할 필요는 없습니다(서버가 다운된 경우).

type: string
Default: disabled
Valid Values: (case insensitive) [DISABLED, ENABLED, communicationEPARING]
가져오기: high

트랜잭션을 사용하여 소스 레코드와 소스 오프셋을 작성하고 새 작업 생성을 생성하기 전에 사전 펜싱하여 클러스터의 소스 커넥터에 대해 정확히 원하는 지원을 활성화할지 여부입니다. 새 클러스터에서 소스 지원을 정확히 활성화하려면 이 속성을 'enabled'로 설정합니다. 기존 클러스터에서 지원을 활성화하려면 먼저 클러스터의 모든 작업자에서 'preparing'으로 설정한 다음 'enabled'로 설정합니다. 두 가지 변경에 롤링 업그레이드를 사용할 수 있습니다. 이 기능에 대한 자세한 내용은 정확하게 제공되는 소스 지원 설명서를 참조하십시오.

유형: int
기본값: 3000 (3초)
가져오기: 높음

Kafka의 그룹 관리 기능을 사용할 때 하트비트에서 그룹 조정자에게 예상되는 시간입니다. 하트비트는 작업자의 세션이 활성 상태로 유지되고 새 멤버가 그룹에 참여할 때 재조정을 용이하게 하는 데 사용됩니다. 값은 session.timeout.ms 보다 작아야 하지만 일반적으로 해당 값의 1/3을 넘지 않아야 합니다. 일반 리밸런스에 대해 예상 시간을 제어하도록 더욱 낮게 조정할 수 있습니다.

type: int
기본값: 60000 (1분)
가져오기: 높음

재조정이 시작되면 각 작업자가 그룹에 참여할 수 있는 최대 시간입니다. 이는 기본적으로 모든 작업에서 보류 중인 데이터를 플러시하고 오프셋을 커밋하는 데 필요한 시간에 대한 제한입니다. 시간 초과가 초과되면 작업자가 그룹에서 제거되어 오프셋 커밋 실패가 발생합니다.

type: int
기본값: 10000(10초)
가져오기: 높음

작업자 오류를 감지하는 데 사용되는 시간 초과입니다. 작업자는 정기적으로 하트비트를 전송하여 브로커에 대한 활성 상태를 나타냅니다. 이 세션 제한 시간이 만료되기 전에 브로커가 브로커에 의해 수신되지 않으면 브로커는 그룹에서 작업자를 제거하고 리밸런스를 시작합니다. 값은 group.min.session.timeout.ms 및 group.max.session.timeout.ms 에 따라 브로커 구성에 구성된 대로 허용 범위에 있어야 합니다.

유형: password
기본값: null
가져오기: 높음

키 저장소 파일의 개인 키 또는 'ssl.keystore.key'에 지정된 PEM 키의 암호입니다.

유형: password
기본값: null
가져오기: 높음

'ssl.keystore.type'로 지정된 형식의 인증서 체인입니다. 기본 SSL 엔진 팩토리에서는 X.509 인증서 목록이 있는 PEM 형식만 지원합니다.

유형: password
기본값: null
가져오기: 높음

'ssl.keystore.type'로 지정된 형식의 개인 키입니다. 기본 SSL 엔진 팩토리에서는 PKCS#8 키를 사용하여 PEM 형식만 지원합니다. 키가 암호화된 경우 'ssl.key.password'를 사용하여 키 암호를 지정해야 합니다.

유형: string
기본값: null
가져오기: 높음

키 저장소 파일의 위치입니다. 이는 클라이언트의 경우 선택 사항이며 클라이언트의 양방향 인증에 사용할 수 있습니다.

유형: password
기본값: null
가져오기: 높음

키 저장소 파일의 저장소 암호입니다. 이는 클라이언트의 경우 선택 사항이며 'ssl.keystore.location'이 구성된 경우에만 필요합니다. 키 저장소 암호는 PEM 형식으로 지원되지 않습니다.

유형: password
기본값: null
가져오기: 높음

'ssl.truststore.type'로 지정된 형식의 신뢰할 수 있는 인증서입니다. 기본 SSL 엔진 팩토리에서는 X.509 인증서가 있는 PEM 형식만 지원합니다.

유형: string
기본값: null
가져오기: 높음

신뢰 저장소 파일의 위치입니다.

유형: password
기본값: null
가져오기: 높음

신뢰 저장소 파일의 암호입니다. 암호를 설정하지 않으면 구성된 신뢰 저장소 파일이 계속 사용되지만 무결성 검사는 비활성화됩니다. PEM 형식으로는 신뢰 저장소 암호가 지원되지 않습니다.

type : string
Default: use_all_dns_ips
Valid Values: [use_all_dns_ips, resolve_canonical_bootstrap_servers_only]
가져오기: 중간

클라이언트에서 DNS 조회를 사용하는 방법을 제어합니다. use_all_dns_ips 로 설정된 경우 성공적으로 연결이 설정될 때까지 반환된 각 IP 주소에 순서대로 연결합니다. 연결 해제 후 다음 IP가 사용됩니다. 모든 IP가 한 번 사용되면 클라이언트는 호스트 이름에서 IP를 다시 확인합니다(JVM 및 OS 캐시 DNS 이름 조회 모두). resolve_canonical_bootstrap_servers_only 로 설정된 경우 각 부트스트랩 주소를 정식 이름 목록으로 확인합니다. 부트스트랩 단계 후 use_all_dns_ips 와 동일하게 작동합니다.

유형: long
기본값: 540000 (9분)
가져오기: 중간

이 구성에서 지정한 시간(밀리초) 후 유휴 연결을 종료합니다.

type: string
Default: All
Importance: medium

ConnectorClientConfigOverridePolicy 구현의 클래스 이름 또는 별칭입니다. 커넥터에서 재정의할 수 있는 클라이언트 구성을 정의합니다. 기본 구현은 모두 입니다. 즉 커넥터 구성이 모든 클라이언트 속성을 재정의할 수 있습니다. 프레임워크의 다른 가능한 정책에는 클라이언트 속성을 재정의하는 커넥터를 허용하지 않는 None 과 커넥터가 클라이언트 주체 만 재정의할 수 있는 보안 주체가 포함됩니다.

type: int
기본값: 32768(32 kibibytes)
유효 값: [0,…​]
가져오기: medium

데이터를 읽을 때 사용할 TCP 수신 버퍼(SO_RCVBUF)의 크기입니다. 값이 -1이면 OS 기본값이 사용됩니다.

type: int
Default: 40000 (40 seconds)
Valid Values: [0,…​]
Importance: medium

구성은 클라이언트가 요청 응답을 기다리는 최대 시간을 제어합니다. 시간 초과가 경과하기 전에 응답이 수신되지 않으면 필요한 경우 클라이언트가 요청을 다시 전송하거나 재시도가 고갈되면 요청이 실패합니다.

유형: class
기본값: null
가져오기: 중간

AuthenticateECDHEbackHandler 인터페이스를 구현하는 SASL 클라이언트 콜백 처리기 클래스의 정규화된 이름입니다.

유형: password
기본값: null
가져오기: 중간

10.0.0.1 구성 파일에서 사용하는 형식의 SASL 연결에 대한 login 컨텍스트 매개변수입니다. 구성 파일 형식은 여기에 설명되어 있습니다. 값 형식은 loginModuleClass 제어Forwarded(optionName=optionValue)*; 입니다. 브로커의 경우 구성 앞에 리스너 접두사 및 SASL 메커니즘 이름을 소문자로 붙여야 합니다. 예를 들어 listener.name.sasl_ssl.scram-sha-256.sasl.config=com.example.ScramLoginModule이 필요합니다.

유형: string
기본값: null
가져오기: 중간

Kafka가 실행되는 Kerberos 사용자 이름입니다. Kafka의 10.0.0.1 구성 또는 Kafka 구성에서 정의할 수 있습니다.

유형: class
기본값: null
가져오기: 중간

AuthenticateECDHEbackHandler 인터페이스를 구현하는 SASL 로그인 콜백 처리기 클래스의 정규화된 이름입니다. 브로커의 경우 로그인 콜백 처리기 구성 앞에 리스너 접두사 및 SASL 메커니즘 이름을 붙여야 합니다. 예를 들어 listener.name.sasl_ssl.scram-sha-256.sasl.login.callback.handler.class=com.example.CustomScramLogin>-<backHandler입니다.

유형: class
기본값: null
가져오기: 중간

로그인 인터페이스를 구현하는 클래스의 정규화된 이름입니다. 브로커의 경우 로그인 구성 앞에 리스너 접두사 및 SASL 메커니즘 이름을 붙여야 합니다. For example, listener.name.sasl_ssl.scram-sha-256.sasl.login.class=com.example.CustomScramLogin.

type: string
Default: GSSAPI
가져오기: 중간

클라이언트 연결에 사용되는 SASL 메커니즘. 이는 보안 공급자를 사용할 수 있는 모든 메커니즘일 수 있습니다. GSSAPI는 기본 메커니즘입니다.

유형: string
기본값: null
가져오기: 중간

공급자의 JWKS(JSON Web Key Set) 를 검색할 수 있는 OAuth/OIDC 공급자 URL입니다. URL은 HTTP(S) 기반 또는 파일 기반일 수 있습니다. URL이 HTTP(S) 기반인 경우 브로커 시작 시 구성된 URL을 통해 OAuth/OIDC 제공업체에서 JWKS 데이터를 검색합니다. 이후의 모든 키는 들어오는 요청에 대해 브로커에 캐시됩니다. 아직 캐시에 없는 "kid" 헤더 클레임 값을 포함하는 JWT에 대한 인증 요청이 수신되면 요청 시 JWKS 끝점을 다시 쿼리합니다. 그러나 브로커는 URL 모든 sasl.oauthbearer.jwks.endpoint.refresh.ms 밀리초를 폴링하여 이를 포함하는 JWT 요청을 수신하기 전에 향후 키로 캐시를 새로 고칩니다. URL이 파일 기반인 경우 브로커는 시작 시 구성된 위치에서 JWKS 파일을 로드합니다. JWT에 JWKS 파일에 없는 "kid" 헤더 값이 포함된 경우 브로커는 JWT를 거부하고 인증이 실패합니다.

유형: string
기본값: null
가져오기: 중간

OAuth/OIDC ID 공급자의 URL입니다. URL이 HTTP(S) 기반인 경우 해당 발행자는 sasl.jaas.config의 구성에 따라 로그인 요청을 수행할 요청의 토큰 끝점 URL입니다. URL이 파일 기반인 경우 권한 부여에 사용할 OAuth/OIDC ID 공급자가 발행한 액세스 토큰( JWT 직렬화 형식)이 포함된 파일을 지정합니다.

type: string
Default: PLAINTEXT
Valid Values: [PLAINTEXT, SSL, SASL_PLAINTEXT, SASL_SSL]
가져오기: 중간

브로커와 통신하는 데 사용되는 프로토콜입니다. 유효한 값은 PLAINTEXT, SSL, SASL_PLAINTEXT, SASL_SSL입니다.

type: int
기본값: 131072(128 키비바이트)
유효 값: [0,…​]
가져오기: medium

데이터를 전송할 때 사용할 TCP 전송 버퍼(SO_SNDBUF)의 크기입니다. 값이 -1이면 OS 기본값이 사용됩니다.

type: list
Default: TLSv1.2,TLSv1.3
가져오기: 중간

SSL 연결에 활성화된 프로토콜 목록입니다. Java 11 이상에서 실행되는 경우 기본값은 'TLSv1.2,TLSv1.3'입니다. 그렇지 않으면 'TLSv1.2'입니다. Java 11의 기본값을 사용하면 클라이언트 및 서버 모두 TLSv1.2로 지원하고 대체(TLSv1.2 이상 지원한다고 가정) TLSv1.3을 선호합니다. 이 기본값은 대부분의 경우에 적합합니다. ssl.protocol 에 대한 구성 설명서도 참조하십시오.

유형: string
기본: JKS
가져오기: 중간

키 저장소 파일의 파일 형식입니다. 이는 클라이언트의 경우 선택 사항입니다. 기본 ssl.engine.factory.class 에서 현재 지원되는 값은 [JKS, PKCS12, PEM]입니다.

type: string
Default: TLSv1.3
가져오기: 중간

SSLContext를 생성하는 데 사용되는 SSL 프로토콜입니다. Java 11 이상, 'TLSv1.2'로 실행할 때 기본값은 'TLSv1.3'입니다. 이 값은 대부분의 사용 사례에 적합합니다. 최근 JVM에서 허용되는 값은 'TLSv1.2' 및 'TLSv1.3'입니다. 'TLS', 'TLSv1.1', 'SSL', 'SSLv2' 및 'SSLv3'는 이전 JVM에서 지원될 수 있지만 알려진 보안 취약점으로 인해 사용이 권장되지 않습니다. 이 구성 및 'ssl.enabled.protocols'의 기본값을 사용하면 서버가 'TLSv1.3'을 지원하지 않는 경우 클라이언트는 'TLSv1.2'로 다운그레이드됩니다. 이 구성이 'TLSv1.2'로 설정된 경우 클라이언트는 ssl.enabled.protocols의 값 중 하나이고 서버는 'TLSv1.3'만 지원하더라도 'TLSv1.3'을 사용하지 않습니다.

유형: string
기본값: null
가져오기: 중간

SSL 연결에 사용되는 보안 공급자의 이름입니다. 기본값은 JVM의 기본 보안 공급자입니다.

유형: string
기본: JKS
가져오기: 중간

신뢰 저장소 파일의 파일 형식입니다. 기본 ssl.engine.factory.class 에서 현재 지원되는 값은 [JKS, PKCS12, PEM]입니다.

유형: int
기본값: 3000 (3초)
가져오기: 중간

작업자가 다른 작업자와 동기화되지 않고 구성을 다시 동기화해야 하는 경우, 다시 가입하기 전에 구성을 다시 동기화하고, 그룹을 종료하고, 백오프 기간을 기다려야 합니다.

유형: int
기본값: 300000 (5분)
가져오기: 중간

작업자가 다른 작업자와 동기화되지 않고 worker.sync.timeout.ms 내에서 catch할 수 없는 경우 다시 가입하기 전에 Connect 클러스터를 이 기간 동안 그대로 둡니다.

유형: string
기본값: ""
가져오기: 낮음

Access-Control-Allow-Methods 헤더를 설정하여 원본 간 요청에 지원되는 메서드를 설정합니다. Access-Control-Allow-Methods 헤더의 기본값은 GET, POST 및 HEAD에 대한 교차 원본 요청을 허용합니다.

유형: string
기본값: ""
가져오기: 낮음

REST API 요청에 대해 Access-Control-Allow-Origin 헤더를 설정하는 값입니다. cross origin 액세스를 사용하려면 이 값을 API에 액세스할 수 있어야 하는 애플리케이션의 도메인으로 설정하거나, 모든 도메인에서 액세스를 허용하는 '*'로 설정합니다. 기본값은 REST API의 도메인에서만 액세스할 수 있습니다.

type: list
Default: null
Valid Values: 쉼표로 구분된 URL 목록(예: http://localhost:8080,https://localhost:8443.
가져오기: 낮음 ).

Admin REST API가 수신 대기할 쉼표로 구분된 URI 목록입니다. 지원되는 프로토콜은 HTTP 및 HTTPS입니다. 빈 문자열 또는 빈 문자열은 이 기능을 비활성화합니다. 기본 동작은 일반 리스너를 사용하는 것입니다('listeners' 속성으로 지정됨).

type: boolean
Default: true
가져오기: low

더 이상 사용되지 않습니다. metric.reporters 에 나열되지 않은 경우에도 JmxReporter를 자동으로 포함할지 여부입니다. 이 구성은 Kafka 4.0에서 제거되며, 대신 JmxReporter를 활성화하려면 org.apache.kafka.common.metrics.JmxReporter 를 metric.reporters 에 포함해야 합니다.

유형: string
기본값: ""
가져오기: 낮음

요청 시 서버로 전달할 id 문자열입니다. 이 목적은 서버 측 요청 로깅에 논리적 애플리케이션 이름을 포함할 수 있도록 허용하여 ip/port를 초과하는 요청 소스를 추적할 수 있습니다.

type: list
Default: ""
가져오기: 낮음

ConfigProvider 클래스의 쉼표로 구분된 이름이 지정된 순서로 로드 및 사용됩니다. 인터페이스 ConfigProvider 를 구현하면 외부 보안과 같은 커넥터 구성에서 변수 참조를 교체할 수 있습니다.

type: short
Default: 3
Valid Values: Kafka 클러스터의 브로커 수보다 크지 않은 Positive 수 또는 브로커의 기본
가져오기: 낮은 값을 사용하는 경우 -1

구성 스토리지 주제를 생성할 때 사용되는 복제 요인입니다.

유형: string
기본값: 세션됨
유효 값: [eager, 호환, 세션]
가져오기: 낮은

Kafka Connect 프로토콜의 호환성 모드입니다.

type: class
Default: org.apache.kafka.connect.storage.SimpleHeaderConverter
가져오기: 낮은

HeaderConverter 클래스는 Kafka Connect 형식과 Kafka에 기록된 직렬화 형식을 변환하는 데 사용됩니다. 이렇게 하면 Kafka에 기록되거나 읽은 메시지의 헤더 값의 형식을 제어할 수 있으며 커넥터가 모든 직렬화 형식으로 작동할 수 있습니다. 일반적인 형식의 예로는 JSON 및 Avro가 있습니다. 기본적으로 SimpleHeaderConverter는 헤더 값을 문자열로 직렬화하고 스키마를 유추하여 역직렬화하는 데 사용됩니다.

type: string
Default: HmacSHA256
Valid Values: worker JVM
가져오기에서 지원하는 모든 KeyGenerator알고리즘: 낮음

내부 요청 키를 생성하는 데 사용하는 알고리즘입니다. 'HmacSHA256' 알고리즘은 이를 지원하는 JVM에서 기본값으로 사용됩니다. 다른 JVM에서는 기본값이 사용되지 않고 이 속성의 값을 작업자 구성에 수동으로 지정해야 합니다.

유형: int
기본값: null
가져오기: 낮음

내부 요청에 서명하는 데 사용할 키의 크기입니다(bit). null인 경우 키 생성 알고리즘의 기본 키 크기가 사용됩니다.

type: int
Default:3600000 (1시간)
Valid Values: [0,…​,2147483647]
가져오기: low

내부 요청 검증(밀리초)에 사용되는 생성된 세션 키의 TTL입니다.

type: string
Default: HmacSHA256
Valid Values: 작업자 JVM
가져오기에서 지원하는 모든 MAC알고리즘: 낮음

알고리즘 'inter.worker.signature.algorithm'은 이를 지원하는 JVM에서 기본값으로 사용됩니다. 다른 JVM에서는 기본값이 사용되지 않고 이 속성의 값을 작업자 구성에 수동으로 지정해야 합니다.

type: list
Default: HmacSHA256
Valid Values: 각각 작업자 JVM
가져오기: 낮음에서 지원하는 하나 이상의 MAC 알고리즘 목록

내부 요청을 확인하기 위해 허용되는 알고리즘 목록입니다. 이 알고리즘에는 inter.worker.signature.algorithm 속성에 사용되는 알고리즘을 포함해야 합니다. 알고리즘 '[HmacSHA256]'은 이를 제공하는 JVM에서 기본값으로 사용됩니다. 다른 JVM에서는 기본값이 사용되지 않으며 이 속성의 값은 작업자 구성에서 수동으로 지정해야 합니다.

type: list
기본값: http://:8083
유효 값: 쉼표로 구분된 URL 목록, ex: http://localhost:8080,https://localhost:8443.
가져오기: 낮음

REST API가 수신 대기할 쉼표로 구분된 URI 목록입니다. 지원되는 프로토콜은 HTTP 및 HTTPS입니다. 모든 인터페이스에 바인딩하려면 hostname을 0.0.0.0으로 지정합니다. 기본 인터페이스에 바인딩할 호스트 이름을 비워 둡니다. 법적 리스너 목록의 예: HTTP://myhost:8083,HTTPS://myhost:8084.

type: long
Default: 300000 (5 minutes)
Valid Values: [0,…​]
가져오기: low

이 기간(밀리초) 후 새 브로커 또는 파티션을 사전에 검색하기 위해 파티션 리더십 변경을 보지 못하더라도 메타데이터를 강제로 새로 고침합니다.

type: list
Default: ""
가져오기: 낮음

메트릭 보고자로 사용할 클래스 목록입니다. org.apache.kafka.common.metrics.MetricsReporter 인터페이스를 구현하면 새 지표 생성에 대한 알림을 받을 클래스를 연결할 수 있습니다. JmxReporter는 항상 통계를 등록하기 위해 포함됩니다.

type: int
Default: 2
Valid Values: [1,…​]
가져오기: 낮음

메트릭으로 유지 관리되는 샘플 수입니다.

type: string
Default: INFO
Valid Values: [INFO, DEBUG]
가져오기: 낮음

메트릭에 대해 가장 높은 기록 수준입니다.

type: long
Default: 30000 (30 seconds)
Valid Values: [0,…​]
가져오기: low

지표 샘플이 계산되는 시간 창입니다.

유형: long
기본값: 60000 (1분)
가져오기: 낮음

작업에 대한 오프셋을 커밋하는 간격입니다.

유형: long
기본값: 5000 (5초)
가져오기: 낮음

프로세스를 취소하고 향후 시도에 커밋할 오프셋된 데이터를 복원하기 전에 레코드를 플러시하고 오프셋된 데이터를 분할하기 위해 커밋할 최대 시간(밀리초)입니다. 이 속성은 정확히 한 번 지원으로 실행되는 소스 커넥터에는 영향을 미치지 않습니다.

type: int
기본값: 25
Valid Values: Positive number 또는 -1은 브로커의 기본값
가져오기: 낮음

오프셋 스토리지 주제를 생성할 때 사용되는 파티션 수입니다.

type: short
Default: 3
Valid Values: Kafka 클러스터의 브로커 수보다 크지 않은 Positive 수 또는 브로커의 기본
가져오기: 낮은 값을 사용하는 경우 -1

오프셋 스토리지 주제를 생성할 때 사용되는 복제 요인입니다.

유형: list
기본값: null
가져오기: 낮음

플러그인(연결자, 변환기, 변환)이 포함된 쉼표(,)로 구분된 경로 목록입니다. 목록은 플러그인과 해당 종속 항목의 패키지 디렉토리 구조를 즉시 포함하는 uber-jars with plugins 및 their dependencies c) 디렉터리를 포함하는 최상위 디렉토리 (a)의 조합을 포함하는 최상위 디렉토리로 구성되어야 합니다. 플러그인 클래스 및 종속 항목의 패키지 디렉토리 구조를 포함하는 디렉터리인 uber-jar는 종속 항목 또는 플러그인을 검색하기 위해 심볼릭 링크를 따릅니다. 예: plugin.path=/usr/local/share/java,/usr/local/share/kafka/plugins,/opt/connectors 이 속성에서 원시 경로를 사용하지 않는 이유는 구성 공급자가 초기화되어 변수를 교체하기 전에 원시 경로를 사용하기 때문입니다.

type: long
Default: 1000 (1 second)
Valid Values: [0,…​]
가져오기: low

브로커에 다시 연결할 때 대기하는 최대 시간(밀리초)입니다. 제공되는 경우 호스트당 백오프는 연속된 연결 실패마다 최대 최대 기하급수적으로 증가합니다. 백오프 증가를 계산한 후 연결 문제가 발생하지 않도록 20 % 임의 지터가 추가됩니다.

type: long
Default: 50
Valid Values: [0,…​]
가져오기: low

지정된 호스트에 다시 연결하기 전에 대기하는 기본 시간입니다. 이렇게 하면 엄격한 루프에서 호스트에 반복적으로 연결하는 것을 방지할 수 있습니다. 이 백오프는 클라이언트가 브로커에 대한 모든 연결 시도에 적용됩니다.

type : string
Default: ""
Valid Values: Comma-separated 헤더 규칙. 여기서 각 헤더 규칙은 '[action] [header name]:[header name]:[header value]' 형식이며, 헤더 규칙의 일부에 쉼표
가져오기: low가 포함된 경우 선택적으로 이중 따옴표로 겹쳐 묶는 헤더 규칙입니다.

REST API HTTP 응답 헤더에 대한 규칙입니다.

유형: string
기본값: null
가져오기: 낮음

이 값을 설정하면 연결할 다른 작업자에게 제공할 호스트 이름입니다.

유형: string
기본값: null
가져오기: 낮음

다른 작업자에게 제공할 공개된 리스너(HTTP 또는 HTTPS)를 설정합니다.

유형: int
기본값: null
가져오기: 낮음

이 값을 설정하면 연결할 다른 작업자에게 제공할 포트입니다.

type: list
Default: ""
가져오기: 낮음

로드되고 지정된 순서로 호출되는 ConnectRestExtension 클래스의 쉼표로 구분된 이름입니다. 인터페이스 ConnectRestExtension 을 구현하면 필터와 같은 Connect의 REST API 사용자 정의 리소스에 삽입할 수 있습니다. 일반적으로 로깅, 보안 등과 같은 사용자 지정 기능을 추가하는 데 사용됩니다.

type: long
Default: 100
Valid Values: [0,…​]
가져오기: low

지정된 주제 파티션에 실패한 요청을 재시도하기 전에 대기하는 시간입니다. 이렇게 하면 일부 실패 시나리오에서 엄격한 루프에서 반복적으로 요청을 보내는 것을 방지할 수 있습니다.

type: string
Default: /usr/bin/kinit
가져오기: low

Kerberos kinit 명령 경로입니다.

유형: long
기본값: 60000
가져오기: 낮음

새로 고침 시도 사이에 로그인 스레드 절전 시간.

유형: double
기본값: 0.05
가져오기: 낮음

임의의 지터의 백분율이 갱신 시간에 추가되었습니다.

유형: double
기본값: 0.8
가져오기: 낮음

로그인 스레드는 마지막 새로 고침에서 티켓 만료까지 지정된 창 요인에 도달할 때까지 유휴 상태가 됩니다. 이 때 티켓을 갱신하려고 합니다.

유형: int
기본값: null
가져오기: 낮음

외부 인증 공급자 연결 시간 초과의 (선택 사항) 값(밀리초)입니다. 현재 OAUTHBEEER에만 적용됩니다.

유형: int
기본값: null
가져오기: 낮음

외부 인증 공급자 읽기 시간(선택 사항)의 (선택 사항) 값(밀리초)입니다. 현재 OAUTHBEEER에만 적용됩니다.

type: short
Default: 300
Valid Values: [0,…​,3600]
가져오기: 낮은

인증 정보를 새로 고칠 때 자격 증명이 만료되기 전의 버퍼 시간(초)입니다. 새로 고침이 버퍼 초 수보다 만료에 더 가까운 경우 최대한 버퍼 시간을 유지하도록 새로 고침이 이동합니다. 적법한 값은 0에서 3600(1시간) 사이이며, 값을 지정하지 않으면 기본값 300(5분)이 사용됩니다. 이 값 및 sasl.login.refresh.min.period.seconds는 합계가 인증 정보의 나머지 수명을 초과하면 무시됩니다. 현재 OAUTHBEEER에만 적용됩니다.

type: short
Default: 60
Valid Values: [0,…​,900]
가져오기: 낮은

로그인 새로 고침 스레드가 인증 정보를 새로 고치기 전에 대기하는 최소 시간(초)입니다. 적법한 값은 0에서 900(15분) 사이이며, 값이 지정되지 않은 경우 기본값 60(1분)이 사용됩니다. 이 값과 sasl.login.refresh.buffer.seconds는 합계가 인증 정보의 나머지 수명을 초과하면 무시됩니다. 현재 OAUTHBEEER에만 적용됩니다.

type: double
Default: 0.8
Valid Values: [0.5,…​,1.0]
가져오기: low

로그인 새로 고침 스레드는 인증 정보의 수명을 기준으로 지정된 창 요소에 도달할 때까지 유휴 상태가 됩니다. 이 시점에서 인증 정보를 새로 고침하려고 합니다. 적법한 값은 0.5(50%)에서 1.0(100%) 사이이며, 값이 지정되지 않은 경우 기본값 0.8(80%)가 사용됩니다. 현재 OAUTHBEEER에만 적용됩니다.

type: double
Default: 0.05
Valid Values: [0.0,…​,0.25]
가져오기: 낮음

로그인 새로 고침 스레드의 절전 시간에 추가되는 인증 정보의 수명을 기준으로 최대 임의 지터입니다. 적법한 값은 0에서 0.25 (25%) 사이이며, 값이 지정되지 않은 경우 기본값 0.05(5%)가 사용됩니다. 현재 OAUTHBEEER에만 적용됩니다.

유형: long
기본값: 10000(10초)
가져오기: 낮음

로그인이 시도한 후 외부 인증 공급자를 시도하는 최대 대기 시간의 (선택 사항) 값(밀리초)입니다. login은 sasl.login.retry.backoff.ms 설정을 기반으로 초기 대기 시간과 함께 지수 백오프 알고리즘을 사용하며, sasl.login.retry.backoff.max.ms 설정으로 지정된 최대 대기 길이까지 시도 사이에 대기 길이를 두 배로 늘어납니다. 현재 OAUTHBEEER에만 적용됩니다.

유형: long
기본값: 100
가져오기: 낮은

로그인 간 초기 대기 시간(선택 사항)에서 외부 인증 공급자를 시도하는 경우 (선택 사항) 값(밀리초)입니다. login은 sasl.login.retry.backoff.ms 설정을 기반으로 초기 대기 시간과 함께 지수 백오프 알고리즘을 사용하며, sasl.login.retry.backoff.max.ms 설정으로 지정된 최대 대기 길이까지 시도 사이에 대기 길이를 두 배로 늘어납니다. 현재 OAUTHBEEER에만 적용됩니다.

유형: int
기본값: 30
가져오기: 낮음

OAuth/OIDC ID 공급자와 브로커 간의 차이점을 허용하는 (선택 사항) 값(선택 사항)입니다.

유형: list
기본값: null
가져오기: 낮음

브로커가 쉼표로 구분된 설정을 사용하여 예상 대상 중 하나에 대해 JWT가 발행되었는지 확인합니다. JWT는 표준 OAuth "공지" 클레임에 대해 검사되며 이 값이 설정된 경우 브로커는 JWT의 "aud" 클레임의 값과 일치하여 정확한 일치가 있는지 확인합니다. 일치하는 항목이 없는 경우 브로커는 JWT를 거부하고 인증이 실패합니다.

유형: string
기본값: null
가져오기: 낮음

브로커가 사용할 (선택 사항) 설정을 사용하여 JWT가 예상 발급자에 의해 생성되었는지 확인합니다. JWT는 표준 OAuth "iss" 클레임에 대해 검사하고 이 값이 설정되면 브로커는 JWT의 "iss" 클레임에 있는 것과 정확히 일치합니다. 일치하는 항목이 없는 경우 브로커는 JWT를 거부하고 인증이 실패합니다.

유형: long
Default:36 00000 (1 hour)
가져오기: 낮음

브로커가 JWT의 서명을 확인하는 키가 포함된 JWKS(JSON Web Key Set) 캐시를 새로 고침할 때까지(선택 사항) 값(선택 사항)입니다.

유형: long
기본값: 10000(10초)
가져오기: 낮음

외부 인증 공급자에서 JWKS(JSON Web Key Set)를 검색하려는 시도 간 최대 대기 시간(밀리초)입니다. JWKS 검색은 sasl.oauthbearer.jwks.endpoint.retry.backoff.ms 설정을 기반으로 초기 대기 알고리즘과 함께 지수 백오프 알고리즘을 사용하며, sasl.oauthbearer.jwks.endpoint.endpoint.retry.backoff.max.ms 설정을 통해 지정한 최대 대기 기간 간 대기 길이를 두 배로 늘립니다.

유형: long
기본값: 100
가져오기: 낮은

JWKS(JSON 웹 키 세트) 검색 시 외부 인증 공급자의 초기 대기 시간(선택 사항) 값(선택 사항)입니다. JWKS 검색은 sasl.oauthbearer.jwks.endpoint.retry.backoff.ms 설정을 기반으로 초기 대기 알고리즘과 함께 지수 백오프 알고리즘을 사용하며, sasl.oauthbearer.jwks.endpoint.endpoint.retry.backoff.max.ms 설정을 통해 지정한 최대 대기 기간 간 대기 길이를 두 배로 늘립니다.

유형: string
기본값: 범위
가져오기: 낮음

범위에 대한 OAuth 클레임은 종종 "범위"라고 하지만, OAuth/OIDC 공급자가 해당 클레임에 대해 다른 이름을 사용하는 경우 JWT 페이로드에 포함된 범위에 사용할 다른 이름을 제공할 수 있습니다.

type: string
Default: sub
가져오기: low

주체에 대한 OAuth 클레임은 종종 "sub"라고 하지만, OAuth/OIDC 공급자가 해당 클레임에 대해 다른 이름을 사용하는 경우 JWT 페이로드에 포함된 항목에 사용할 다른 이름을 제공할 수 있습니다.

type: int
Default: 300000 (5 minutes)
Valid Values: [0,…​,2147483647]
가져오기: low

커넥터와 작업을 그룹에 재조정하고 다시 할당하기 전에 하나 이상의 지정된 작업자의 반환을 대기하도록 예약된 최대 지연입니다. 이 기간 동안 지정된 작업자의 커넥터와 작업은 할당되지 않은 상태로 유지됩니다.

type: long
Default: 30000 (30 seconds)
Valid Values: [0,…​]
가져오기: low

클라이언트가 소켓 연결이 설정될 때까지 대기하는 최대 시간입니다. 연결 설정 시간 초과는 최대의 연속 연결 실패에 대해 기하급수적으로 증가합니다. 연결 태우를 피하기 위해 0.2의 무작위 요소가 계산된 값 위의 20 %에서 20 % 사이의 무작위 범위를 초래합니다.

type: long
Default: 10000 (10 seconds)
Valid Values: [0,…​]
가져오기: low

클라이언트가 소켓 연결이 설정될 때까지 대기하는 시간입니다. 시간 초과가 종료되기 전에 연결이 빌드되지 않으면 클라이언트는 소켓 채널을 종료합니다.

유형: list
기본값: null
가져오기: 낮음

암호화 제품군 목록입니다. TLS 또는 SSL 네트워크 프로토콜을 사용하여 네트워크 연결의 보안 설정을 협상하는 데 사용되는 인증, 암호화, MAC 및 키 교환 알고리즘의 이름 지정된 조합입니다. 기본적으로 사용 가능한 모든 암호화 제품군이 지원됩니다.

type: string
Default: none
Valid Values: [required, requested, none]
가져오기: 낮은

클라이언트 인증을 요청하도록 kafka 브로커를 구성합니다. 다음 설정은 일반적입니다.

유형: string
기본값: https
가져오기: 낮음

서버 인증서를 사용하여 서버 호스트 이름을 검증하는 끝점 식별 알고리즘입니다.

유형: class
기본값: null
가져오기: 낮음

SSLEngine 개체를 제공하는 org.apache.kafka.common.security.auth.SslEngineFactory 유형의 클래스입니다. Default value is org.apache.kafka.common.security.ssl.DefaultSslEngineFactory.

유형: string
Default: SunX509
가져오기: 낮음

SSL 연결에 대해 키 관리자 팩토리에서 사용하는 알고리즘입니다. 기본값은 Java 가상 머신에 대해 구성된 키 관리자 팩토리 알고리즘입니다.

유형: string
기본값: null
가져오기: 낮음

SSL 암호화 작업에 사용할 SecureRandomECDHE 구현입니다.

유형: string
Default: PKIX
가져오기: 낮음

신뢰 관리자 팩토리에서 SSL 연결에 사용하는 알고리즘입니다. 기본값은 Java 가상 머신에 대해 구성된 신뢰 관리자 팩토리 알고리즘입니다.

type: int
기본값: 5
Valid Values: Positive number 또는 -1은 브로커의 기본값
가져오기: 낮음

상태 스토리지 주제를 생성할 때 사용되는 파티션 수입니다.

type: short
Default: 3
Valid Values: Kafka 클러스터의 브로커 수보다 크지 않은 Positive 수 또는 브로커의 기본
가져오기: 낮은 값을 사용하는 경우 -1

상태 스토리지 주제를 생성할 때 사용되는 복제 요인입니다.

유형: long
기본값: 5000 (5초)
가져오기: 낮음

작업이 정상적으로 종료될 때까지 대기하는 시간입니다. 이는 작업 수가 아닌 총 시간입니다. 모든 작업이 종료 트리거된 후 순차적으로 대기됩니다.

type: boolean
Default: true
가져오기: low

소스 커넥터가 사용하는 항목의 자동 생성을 허용하는지 여부입니다 topic.creation. 속성으로 소스 커넥터를 구성할 때입니다. 각 작업은 admin 클라이언트를 사용하여 해당 주제를 생성하고 Kafka 브로커에 따라 자동으로 주제를 생성하지 않습니다.

type: boolean
Default: true
가져오기: low

true로 설정하면 커넥터당 활성 주제 집합을 재설정하도록 사용자 요청을 수행할 수 있습니다.

type: boolean
Default: true
가져오기: low

런타임 중 커넥터당 활성 주제 집합을 추적할 수 있습니다.