문서 홈 → 애플리케이션 개발 → MongoDB Kafka Connector
Kafka Connect MongoDB에서 마이그레이션
이 가이드를 사용하여 커뮤니티에서 생성한 Kafka Connect MongoDB 에서 Kafka 배포를 마이그레이션합니다. 싱크 커넥터를 공식 MongoDB Kafka 커넥터에 연결합니다.
다음 섹션에서는 MongoDB Kafka 싱크 connector로 전환하기 위해 Kafka Connect 싱크 커넥터 구성 설정 및 사용자 지정 클래스를 변경해야 하는 사항을 설명합니다.
구성 설정 업데이트
MongoDB Kafka connector 배포에 사용하기 전에 Kafka Connect 배포의 구성 설정을 다음과 같이 변경합니다.
at.grahsl.kafka.connect.mongodb패키지를 포함하는 값을com.mongodb.kafka.connect패키지로 바꿉니다.connector.class설정을 MongoDB Kafka connector 클래스로 바꿉니다.connector.class=com.mongodb.kafka.connect.MongoSinkConnector Kafka Connect 속성 이름에서
mongodb.접두사를 제거합니다. 예를 들어mongodb.connection.uri을connection.uri로 변경합니다.document.id.strategies설정이 있는 경우 이를 제거합니다. 이 설정의 값이 사용자 지정 전략을 참조하는 경우 해당 전략을document.id.strategy설정으로 이동하세요. 사용자 지정 클래스 업데이트 섹션을 읽고 사용자 지정 클래스에 어떤 변경 사항을 적용해야 하는지 알아보세요.mongodb.collection접두사가 포함된 주제별 또는 collection 재정의를 지정하는 데 사용하는 모든 속성 이름을 connector Kafka 주제 구성 주제 속성에서 해당 키로 바꿉니다.
사용자 지정 클래스 업데이트
Kafka Connect 싱크 connector 배포에서 사용자 지정 클래스를 사용하는 경우 MongoDB Kafka connector 배포에 추가하기 전에 다음과 같이 변경합니다.
at.grahsl.kafka.connect.mongodb을 포함하는 가져오기를com.mongodb.kafka.connect으로 바꿉니다.MongoDbSinkConnector클래스에 대한 참고를MongoSinkConnector클래스로 바꿉니다.사용자 지정 싱크 connector 전략 클래스를 업데이트하여
com.mongodb.kafka.connect.sink.processor.id.strategy.IdStrategy인터페이스를 구현합니다.MongoDbSinkConnectorConfig클래스에 대한 참고를 업데이트합니다. MongoDB Kafka Connector에서 해당 클래스의 로직은 다음 클래스로 분할됩니다.
포스트 프로세서 서브클래스 업데이트
Kafka Connect 커넥터 배포에서 포스트 프로세서를 서브클래스화하는 클래스가 있는 경우, MongoDB Kafka 커넥터 PostProcessor 포스트 프로세서 클래스의 메서드 서명과 일치하도록 Kafka Connect 클래스의 메서드를 재정의하는 메서드를 업데이트합니다 .