DevOps/Kafka
Kafka - 프로듀서(Prosucer)
카프카에서 프로듀서는 카프카 클러스터에 메시지를 전달하는 역할을 한다.크게 프로듀서 속성 정의, 프로듀서 생성, 데이터 전송, 프로듀서 종료 순으로 진행한다. 중간에 시리얼라이저(Serializer)가 있는데, 이건 카프카로 메시지를 보낼때, Key:Value 쌍으로 메시지를 보낸다.이때 메시지는 입력값으로 보내는 것이 아닌, Byte값으로 변하여 전송이 되는데 그때 변환할 형식을 의미한다.가령 key값이 1,2,3이라면 Int도 상관없지만, 문자열(test_1, Log....etc)라면 String을 사용한다. 그렇게 정의된 각각의 시리얼라이저를 Producer에 담아 보낸다.public class ProducerDemo{ private Static final Logger log = LoggerFact..
2025. 1. 17.