카프카 프로듀서

프로듀서란 ? 

카프카 브로커로 보내주는 역할을 하는 것

 

1. ProducerRecord 객체를 Serializer  를  사용하여 전송에 적합하게 직렬화 한다. 

2. 파티셔너가 해당 레코드가 저장될 파티션을 결정 짓는다. 

3. 파티션이 결정되면 프로듀서가 저장될 토픽과 레코드를 알게 된다.

4. 레코드가 해당하는 토픽의 파티션에 저장된다. 

5. 브로커는 수신된 레코드의 메세지를 처리한 후 응답을 전송한다. 

6. 성공하면 RecordMetadata 객체를 반환하고 실패하면 에러를 반환하고, 프로듀서는 리트라이를 설정에 따라하게 된다.

 

카프카 프로듀서 만들기 

ProducerRecord 의  메세지를