MongoDB Sink 커넥터
MongoDB Sink 커넥터
MongoDB sink 커넥터는 Pulsar 토픽에서 메시지를 가져와 MongoDB 컬렉션에 저장하는 커넥터예요. Pulsar의 데이터를 MongoDB로 흘려보낼 때 사용해요.
참고: 모든 Pulsar 커넥터는 download page에서 내려받을 수 있어요.
출처: 문서
본문
구성 (Configuration)
MongoDB sink 커넥터의 구성에는 다음과 같은 프로퍼티가 있어요.
프로퍼티 (Property)
| 이름 | 타입 | 필수 | 기본값 | 설명 |
|---|---|---|---|---|
| mongoUri | String | true | " " (빈 문자열) | 커넥터가 연결하는 MongoDB URI예요. 더 자세한 내용은 connection string URI format을 참고하세요. |
| database | String | true | " " (빈 문자열) | 컬렉션이 속한 데이터베이스 이름이에요. |
| collection | String | true | " " (빈 문자열) | 커넥터가 메시지를 쓰는 컬렉션 이름이에요. |
| batchSize | int | false | 100 | 컬렉션에 메시지를 쓸 때의 배치 크기예요. |
| batchTimeMs | long | false | 1000 | 배치 작업 간격(밀리초)이에요. |
예제 (Example)
Mongo sink 커넥터를 사용하기 전에 다음 방법 중 하나로 구성 파일을 만들어야 해요.
- JSON
{
"configs": {
"mongoUri": "mongodb://localhost:27017",
"database": "pulsar",
"collection": "messages",
"batchSize": "2",
"batchTimeMs": "500"
}
}
- YAML
configs:
mongoUri: "mongodb://localhost:27017"
database: "pulsar"
collection: "messages"
batchSize: 2
batchTimeMs: 500