Kafka

정의카프카 클라이언트와 데이터를 주고받기 위해 사용하는 주체데이터를 분산 저장하여 장애가 발생해도 안전하게 사용할 수 있음실행 단위하나의 서버에는 한개의 카프카 브로커 프로세스가 실행된다기능단일 브로커로도 구성이 가능하지만,보통 REDIS Sentienl 같이 데이터의

Spring FW 에서 제공하는 Kafka 통합 기능의 일부특정 카프카 토픽으로부터 메시지를 수신하기 위해 메서드 레벨에서 사용하는 어노테이션메시지 수신의 역할@KafkaListener 로 해당 메서드가 Kafka 토픽으로부터 메시지를 수신할 것임을 명시한다.토픽 구독

멱등성 프로듀서데이터의 중복 적재 없이 메시지를 정확히 한 번만 적재하도록 보장한다.기본 프로듀서와 다르게 동작한다. 데이터를 Kafka 브로커로 전송할 때, 각 메시지에서는 프로듀서의 고유 IP (PID) 와 시퀀스 번호(SID) 가 포함된다.해당 정보를 통하여 Ka

카프카에서 메시지를 전송하는 경우, 객체를 직렬화되어 바이트배열로 변환되고해당 바이트 배열은 카프카 토픽을 통해 전송된다.근데.. 바이트 배열을 원 객체로 역직렬화시에 ObjectId 가 변경되는 문제가 있었음..그냥 ObjectId 로 받는 게 의미가 없다고 생각하여