Kafka : Kafka Producer에 관하여

1. Kafka Producer 의 시작

2. Kafka Producer 주요 옵션

옵션 설명
bootstrap.servers 카프카 클러스터에 연결하기 위한 호스트, 포트 정보 설정
client.dns.lookup 클라이언트가 하나의 IP와 연결하지 못할 경우에 다른 IP로 시도하는 설정
acks 카프카 메세지 수신에 대한 확인 수준 설정
buffer.memory 프로듀서가 카프카로 데이터를 보내기 위한 대기 메모리 바이트(byte) 설정
compression.type 프로듀서 메세지 전송시 압축 타입 설정(none, gzip, snappy, lz4, zstd 등)
max.in.flight.requests.per.connection 프로듀서가 한 번에 몇 개의 요청(Request)을 전송할 것인가에 대한 설정(ACK 없이 전송할 최대 요청 수)
retries 일시적인 장애에 대해 몇 번 재시도 할 것인가에 대한 설정
batch.size 프로듀서의 배치의 사이즈를 결정하는 결정하는 설정
linger.ms 프로듀서의 배치 메세지를 보내기 전에 추가적인 메세지를 위해 기다리는 시간 설정
transactional.id ???
enable.idempotence ???

3. Kafka Producer Transaction