작성한 질문수
[아파치 카프카 애플리케이션 프로그래밍] 개념부터 컨슈머, 프로듀서, 커넥트, 스트림즈까지!
분산모드 커넥트
작성
·
198
0
안녕하세요 선생님.
커넥트를 실행할 때 설정 파일에 key.converter, value.converter와 같은 값들이 있는데, 이런 값들을 커넥트 단위가 아니라 커넥터 단위로 주려면 어떻게 해야 하나요?
예를 들어, MySQL의 싱크 커넥터, 몽고DB의 소스 커넥터 이런 식으로 각각 다르게 주려면 어떻게 하나요?
REST API로 커넥터를 등록할 때 json에 값을 넣어주면 덮어쓰기 되는 식으로 혹시 동작하나요?
답변 1
2
돈가스날다님, 사용하시려는 커넥터마다 다르지만 기본적으론 value.converter, key.converter와 같은 형태로 오버라이드하여 사용하실 수 있습니다. 오픈소스 Mongodb Connector의 컨버터 사용 설명서 https://www.mongodb.com/docs/kafka-connector/current/introduction/converters/ 를 참고하시면 더 좋을것 같습니다.