Aerospike sink 커넥터

Aerospike sink 커넥터는 Pulsar 토픽에서 메시지를 가져와 Aerospike 클러스터로 보내요. Pulsar에서 발생한 이벤트를 Aerospike 같은 외부 키-값 저장소에 기록하고 싶을 때 사용하면 좋아요.

모든 Pulsar 커넥터는 다운로드 페이지에서 내려받을 수 있어요. 커넥터를 사용하기 전에 아래 표의 설정 속성을 보고 필요한 값을 채워 두세요.

출처: 문서

본문

알아두기: 모든 Pulsar 커넥터는 다운로드 페이지에서 다운로드할 수 있어요.

Aerospike sink 커넥터는 Pulsar 토픽에서 메시지를 가져와 Aerospike 클러스터로 보내요.

Aerospike sink 커넥터의 구성은 다음 속성을 가져요.

이름	타입	필수	기본값	설명
seedHosts	String	true	기본값 없음	콤마로 구분된 하나 이상의 Aerospike 클러스터 호스트 목록. 각 호스트는 유효한 IP 주소 또는 호스트 이름 뒤에 선택적 포트 번호로 지정할 수 있어요.
keyspace	String	true	기본값 없음	Aerospike 네임스페이스.
columnName	String	true	기본값 없음	Aerospike 컬럼 이름.
userName	String	false	NULL	Aerospike 사용자 이름.
password	String	false	NULL	Aerospike 비밀번호.
keySet	String	false	NULL	Aerospike 세트 이름.
maxConcurrentRequests	int	false	100	sink가 열 수 있는 최대 동시 Aerospike 트랜잭션 수.
timeoutMs	int	false	100	이 속성은 Aerospike 트랜잭션의 socketTimeout과 totalTimeout을 제어해요.
retries	int	false	1	Aerospike에 쓰기 트랜잭션을 중단하기 전 최대 재시도 횟수.