sink로 등록된 topic의 값이 db에 반영되지 않습니다.
611
작성한 질문수 5
sink도 잘 등록되었고, orders topic에 json 값도 잘 전달되지만 전달된 값이 디비에는 반영되지 않아 데이터 삽입이 되지 않습니다. ㅠㅠ
무엇이 문제일까요?
답변 1
0
안녕하세요, 이도원입니다.
올려주신 에러로 정확한 원인을 파악하기 어렵지만, 우선 내용을 정리해 보면,
생성 된 토픽에 대한 테이블이 mydb에 자동으로 생성됨
토픽(orders)에 메시지가 잘 전달 됨
토픽에 전달되는 메시지가 테이블에 저장되지 않음
이렇게 3가지 단계로 요약할 수 있을 것 같은데, 우선 1번은 mydb에서 테이블을 삭제한 다음, 자동으로 다시 생성되는지 확인해 보시면 좋을 것 같습니다. 2번은 어디에서 메시지를 전송하는지는 모르겠지만 (예, source conntor) 해당 토픽에 메시지가 잘 되는지 확인해 보기 위해, 기존 토픽을 삭제하고 다시 실행해 보시는게 좋을 것 같습니다. 만약 소스커넥터에 의해 DB에서 가져오는 데이터가 토픽에 저장되는 거라면, 해당 메시지의 스키마하고 기존에 저장되었던 스키마하고 비교해서 같은 형식인지 확인해 보시기 바랍니다. 소스커넥터에 의해서 가져온 스키마(Json 포맷)가 제일 정확할 겁니다. 해당 Json 포맷의 데이터를 직접 토픽에 전송 하였을 때(console producer 등 사용) Sink Connector가 정상적으로 작동중이라면, Sink Connector와 연결된 DB에 데이터가 저장되어야 합니다. 만약 위에 말씀드린 내용외에 추가로 확인해 볼 것은, Kafka Broker하고 Kafka Connectr가 잘 연결된 것인지도 확인해 보시면 좋을 것 같습니다.
감사합니다.
kafka 업데이트 강의 듣고 시포요
0
89
2
강의 교안
0
79
2
마이크로서비스간 통신 시, 인증 처리
0
87
2
api gateway 에서 인증 처리
0
66
1
섹션 19 질문드립니다
0
60
2
강의 자료 업데이트
0
86
2
부하분산 강의 섹션
0
59
1
강의자료는 어디에서?
0
76
2
강의 자료는 어디서 다운 받을 수 있나요?
0
114
2
전체 사용자 조회시 오류
0
60
1
혹시 pk 외 별도의 id 를 부여한 이유가 있을까요 ??
0
113
2
학습 방향
0
96
2
카프카 커넥터 사용 목적 문의
0
87
2
kafka 강의
0
109
2
서비스 디스커버리 종류
0
87
2
강의 자료에 대해서 궁금해요
0
119
2
GlobalFilter, LoggingFilter가 동작하지 않습니다.
0
91
2
Kafka Source Connect 버전 에러
0
90
2
소스커넥터는 사용안한 거 맞죠?
0
82
2
강의자료 업데이트 문의
0
97
2
강의에서 BCryptPasswordEncoder 에 역할(5-2)
0
59
1
강의 업데이트 계획이 궁금합니다.
0
114
2
MSA 애플리케이션에 Spring Web과 Spring Data JPA를 사용하는 것이 바람직한지 궁금합니다. (MSA 설계와 관련된 질문입니다)
0
163
2
어떤 것이 업데이트 된 건가요?
0
167
2