kafka - producer, consumer

kafka 구동 방식

1 zookeeper 및 kafka 서버 먼저 구동

zookeeper 서버구동

kafka 서버구동

producer

토픽을 먼저 생성 후 메시지 보 내는 것

consumer

메시지 받고 싶은 토픽을 골라서 받는 중

새로운 컨슈머가 관련 토픽 정하면 처음부터 다 받아옴

토픽확인

마리아db 정보 추가

마리아디비에서 정보추가한거 컨슈머로 확인

sink connector 설정

kafka sink connector 사용하면

마리아 디비에 추가하는 정보가 sink connect 된 테이블 정보가 바로 넘어가서 저장됨

컨슈머파트에도 자동적으로 갱신