<aside> 1️⃣ Producer와 Consumer란?

</aside>

1. Producer
   • Kafka에 데이터를 쓰는 역할을 하는 클라이언트 애플리케이션이다. 메시지를 특정 토픽의 파티션에 전송한다.

• 역할: Kafka 토픽의 파티션에 메시지를 전송

• Spring Boot 코드 예시:KafkaTemplate을 사용하여 특정 토픽에 메시지를 쉽게 전송할 수 있다.

  @Autowired
  private KafkaTemplate<String, String> kafkaTemplate;
  
  public void sendMessage(String topic, String message) {
      kafkaTemplate.send(topic, message);
  }
  

1. Consumer
   • Kafka에서 데이터를 읽는 역할을 하는 클라이언트 애플리케이션이다. 특정 토픽의 파티션에서 메시지를 가져온다.

• 역할: Kafka 토픽의 파티션에서 메시지를 가져와 처리

• Spring Boot 코드 예시:@KafkaListener 어노테이션을 사용하여 특정 토픽과 그룹 ID를 지정하고 메시지를 수신한다.

  @KafkaListener(topics = "myTopic", groupId = "myGroup")
  public void listen(String message) {
      System.out.println("Received Message: " + message);
  }
  

1. 그림 예시

• Producer 1과 Producer 2: 각각 Topic A의 Partition 1과 Partition 2로 메시지를 보냅니다.
• Consumer 1과 Consumer 2: 각각 Topic A의 Partition 1과 Partition 2에서 메시지를 읽습니다.

<aside> 2️⃣ Producer의 동작방식

</aside>

• Producer는 Broker에 메시지를 전송하는 역할을 한다. 주로 다음과 같은 단계를 거친다.

1. Initialization: Producer가 시작되면, 설정에 따라 Kafka Broker와의 연결을 초기화한다.
2. Topic Selection: 메시지를 전송할 토픽을 선택한다.
3. Partitioning: 선택한 토픽 내에서 메시지를 저장할 파티션을 결정한다. 이는 라운드-로빈, 키 해싱 등의 방식으로 이루어질 수 있다.
4. Message Sending: 결정된 파티션에 메시지를 전송한다. 이 단계에서는 메시지 전송 방식을 선택한다.
   • 동기 전송(Synchronous Sending):
     • 메시지를 보낸 후, Broker로부터 Acknowledge(응답)을 명시적으로 기다린다. 응답이 오면 다음 메시지를 보낸다.
   • 비동기 전송(Asynchronous Sending):
     • 메시지를 보낸 후, Broker로부터의 Acknowledge(응답)을 기다리지 않고 바로 다음 메시지를 보낸다. 이 경우, 설정에 따라 나중에 일괄적으로 Acknowledge를 처리할 수 있다.
5. Acknowledge: 메시지 전송 후, 설정에 따라 Broker로부터 응답을 받을 수 있다. 이 단계는 4번 단계에서 선택한 메시지 전송 방식에 따라 동작한다. Acknowledge는 메시지가 성공적으로 Broker에 저장되었는지 확인하는 단계이다.
   • 4~5번은 한묶음의 단계인가?