MongoDB Source 커넥터
MongoDB Source 커넥터
MongoDB source 커넥터는 MongoDB에서 도큐먼트를 가져와 그 메시지를 Pulsar 토픽에 저장하는 커넥터예요. 이 가이드는 MongoDB source 커넥터를 구성하고 사용하는 방법을 설명해요.
참고: 모든 Pulsar 커넥터는 download page에서 내려받을 수 있어요.
출처: 문서
본문
구성 (Configuration)
MongoDB source 커넥터의 구성에는 다음과 같은 프로퍼티가 있어요.
프로퍼티 (Property)
| 이름 | 타입 | 필수 | 기본값 | 설명 |
|---|---|---|---|---|
| mongoUri | String | true | " " (빈 문자열) | 커넥터가 연결하는 MongoDB URI예요. 더 자세한 내용은 connection string URI format을 참고하세요. |
| database | String | false | " " (빈 문자열) | 감시할 데이터베이스 이름이에요. 이 필드를 설정하지 않으면 source 커넥터는 MongoDB 전체의 모든 변경을 감시해요. |
| collection | String | false | " " (빈 문자열) | 감시할 컬렉션 이름이에요. 이 필드를 설정하지 않으면 source 커넥터는 데이터베이스의 모든 변경을 감시해요. |
| syncType | String | false | "INCR_SYNC" | MongoDB와 Pulsar 사이의 동기화 타입이에요. 전체 동기화(full synchronization) 또는 증분 동기화(incremental synchronization)를 의미해요. 유효한 값은 full_sync, FULL_SYNC, incr_sync, INCR_SYNC예요. |
| batchSize | int | false | 100 | 컬렉션에서 도큐먼트를 가져올 때의 배치 크기예요. |
| batchTimeMs | long | false | 1000 | 배치 작업 간격(밀리초)이에요. |
예제 (Example)
Mongo source 커넥터를 사용하기 전에 다음 방법 중 하나로 구성 파일을 만들어야 해요.
- JSON
{
"configs": {
"mongoUri": "mongodb://localhost:27017",
"database": "pulsar",
"collection": "messages",
"syncType": "full_sync",
"batchSize": "2",
"batchTimeMs": "500"
}
}
- YAML
configs:
mongoUri: "mongodb://localhost:27017"
database: "pulsar"
collection: "messages"
syncType: "full_sync",
batchSize: 2
batchTimeMs: 500