Kafka Producer

22/07/23

Producer Options

22/07/23

Option 은 크게 Mandatory 와 Optional 로 나뉘어진다.

• 필수옵션 (mandatory)

  • default 로 지정되는 값이 없다. 초기에 사용자가 필수로 지정해줘야하는 옵션 값을 의미한다.

• 선택 옵션 (optional)

  • 기본적으로 default 값들이 지정되는 option 들이다.
  • 중요 ) 라이브러리의 version 에 따라 default 값은 바뀔 수 있다.!! 따라서 어떤 버전을 적용했는지 잘 확인하고 적용해야한다.

Kafka Broker

22/07/23

background

kafka 를 통해 받아오는 실시간 데이터를 websocket을 통해 consume 과 동시에 send 하는 로직

KafkaListener 를 통해 data를 consume 하는데 consume 을 하나만해서 한 데이터에 대해 send 처리가 되어야하는데,

같은 record가 반복해서 consumer 이 들어오고, 갯수를 세어보면 offset이 0 인 값부터 반복적으로 들어오는것 같다.

console 을 통해 consume 하는 것을 확인해보면 정상적으로 하나의 레코드가 받아지는것을 확인할 수 있다.

Sending Message

• https://docs.spring.io/spring-kafka/reference/html/#sending-messages

Consumer Group

Consumer Options

• Mandatory
• Optional