Solr Sink 커넥터
Solr Sink 커넥터
Solr sink 커넥터는 Pulsar 토픽에서 메시지를 가져와 Solr 컬렉션에 저장하는 커넥터예요. Pulsar의 데이터를 검색 플랫폼인 Apache Solr에 써 넣을 때 사용해요.
참고: 모든 Pulsar 커넥터는 download page에서 내려받을 수 있어요.
출처: 문서
본문
구성 (Configuration)
Solr sink 커넥터의 구성에는 다음과 같은 프로퍼티가 있어요.
프로퍼티 (Property)
| 이름 | 타입 | 필수 | 기본값 | 설명 |
|---|---|---|---|---|
| solrUrl | String | true | " " (빈 문자열) | SolrCloud 모드에서 chroot와 함께 사용하는 쉼표 구분 Zookeeper 호스트 목록이에요. 예: localhost:2181,localhost:2182/chroot. standalone 모드에서 Solr에 연결하는 데 사용하는 URL이에요. 예: localhost:8983/solr |
| solrMode | String | true | SolrCloud | Solr 클러스터와 상호작용할 때의 클라이언트 모드예요. 사용 가능한 옵션은 다음과 같아요. Standalone, SolrCloud |
| solrCollection | String | true | " " (빈 문자열) | 레코드를 써야 하는 Solr 컬렉션 이름이에요. |
| solrCommitWithinMs | int | false | 10 | Solr가 커밋을 업데이트할 시간(밀리초)이에요. |
| username | String | false | " " (빈 문자열) | 기본 인증(basic authentication)에 사용하는 사용자 이름이에요. 참고: 사용자 이름은 대소문자를 구분해요. |
| password | String | false | " " (빈 문자열) | 기본 인증에 사용하는 비밀번호예요. 참고: 비밀번호는 대소문자를 구분해요. |
예제 (Example)
Solr sink 커넥터를 사용하기 전에 다음 방법 중 하나로 구성 파일을 만들어야 해요.
- JSON
{
"configs": {
"solrUrl": "localhost:2181,localhost:2182/chroot",
"solrMode": "SolrCloud",
"solrCollection": "techproducts",
"solrCommitWithinMs": 100,
"username": "fakeuser",
"password": "fake@123"
}
}
- YAML
configs:
solrUrl: "localhost:2181,localhost:2182/chroot"
solrMode: "SolrCloud"
solrCollection: "techproducts"
solrCommitWithinMs: 100
username: "fakeuser"
password: "fake@123"