4장. 생산자 구성 속성

key.serializer

유형: class
중요도: high

org.apache.kafka.common.serialization.Serializer 인터페이스를 구현하는 키에 대한 직렬화r 클래스입니다.

value.serializer

유형: class
중요도: high

org.apache.kafka.common.serialization.Serializer 인터페이스를 구현하는 값에 대한 직렬화r 클래스입니다.

bootstrap.servers

type: list
Default: ""
Valid Values: non-null string
Importance: high

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

buffer.memory

type: long
Default: 33554432
Valid Values: [0,…]
가져오기: high

생산자가 서버로 전송되는 대기 중인 레코드를 버퍼링하는 데 사용할 수 있는 총 메모리 바이트입니다. 레코드가 서버에 전달할 수 있는 속도보다 빠르게 전송되는 경우 프로듀서가 max.block.ms 를 위해 차단된 후 예외가 발생합니다.

이 설정은 생산자가 사용할 총 메모리와 대략적으로 일치해야 하지만, 생산자가 사용하는 모든 메모리가 버퍼링에 사용되는 것은 아니므로 하드 바인딩되지는 않습니다. 일부 추가 메모리는 압축( 압축이 활성화된 경우)과 진행 중인 요청을 유지 관리하는 데 사용됩니다.

compression.type

type: string
Default: none
Valid Values: [none, gzip, snappy, lz4, zstd]
가져오기: high

프로듀서에서 생성한 모든 데이터의 압축 유형입니다. 기본값은 none입니다(예: 압축 없음). 유효한 값은 none,gzip,snappy,lz4, zstd 입니다. 압축은 데이터의 전체 일괄 처리이므로 일괄 처리 속도는 압축 비율에도 영향을 미칩니다(더 많은 일괄 처리는 더 나은 압축을 의미합니다).

retries

type: int
기본값: 2147483647
유효한 값: [0,…,2147483647]
가져오기: high

값을 0보다 크게 설정하면 클라이언트가 전송이 잠재적으로 일시적인 오류와 함께 실패하는 모든 레코드를 다시 보냅니다. 이 재시도는 클라이언트가 오류를 수신할 때 레코드를 재지정하는 경우와 다르지 않습니다. 승인에 성공하기 전에 delivery.timeout.ms 로 구성한 타임아웃이 먼저 만료되면 재시도 횟수가 만료되기 전에 생성 요청이 실패합니다. 일반적으로 사용자는 이 구성을 설정되지 않은 상태로 두고 delivery.timeout.ms 를 사용하여 재시도 동작을 제어해야 합니다.

idempotence를 활성화하려면 이 구성 값이 0보다 커야 합니다. 구성이 설정되고 idempotence가 명시적으로 활성화되어 있지 않으면 idempotence가 비활성화됩니다.

enable.idempotence 를 false 로 설정하고 max.in.flight.requests.per.connection 을 1로 설정하면 두 개의 배치가 단일 파티션으로 전송되고 첫 번째 배치가 실패하고 두 번째 배치의 레코드가 먼저 표시될 수 있으므로 레코드 순서가 변경될 수 있습니다.

ssl.key.password