카프카 프로듀서의 메세지 전송 매커니즘

Created
January 15, 2023
Created by
D
DaEun Kim
Tags
Kafka
Property

동기

  • 브로커로부터 ACK 받을 때까지 메인쓰레드에서 대기한다.
  • 안정적인 메세지 전송 처리가 가능하겠지만 메세지 전송이 빈번하게 발생하는 운영 환경에는 적절하지 않다.
  • java 기반의 kafka-client 에서는 KafkaProducer().send(…).get() 과 같이 동기방식으로 메세지 전송이 가능하다.
  • 예제코드
image

비동기

  • 브로커로부터 ACK 받을 때 까지 대기하지 않고 ACK 결과는 콜백함수에서 처리한다.
  • java 기반의 kafka-client 는 쓰레드를 새로 생성해서 메세지를 전송하고 콜백을 처리한다.
  • 예제코드
image
image