HTTP Sink 커넥터

HTTP Sink 커넥터

HTTP sink 커넥터는 Pulsar 토픽에서 레코드를 가져와 설정 가능한 HTTP URL(웹훅)로 POST 요청을 보내는 커넥터예요. Pulsar의 데이터를 웹 서비스나 웹훅 엔드포인트로 전달할 때 유용해요.

참고: 모든 Pulsar 커넥터는 download page에서 내려받을 수 있어요.

출처: 문서

본문

HTTP 요청의 본문(body)은 레코드 값의 JSON 표현이에요. HTTP 요청에는 Content-Type: application/json 헤더가 추가돼요.

HTTP 요청에는 다음과 같은 다른 HTTP 헤더도 추가돼요.

  • PulsarTopic: 레코드의 토픽
  • PulsarKey: 레코드의 키
  • PulsarEventTime: 레코드의 이벤트 시간
  • PulsarPublishTime: 레코드의 발행 시간
  • PulsarMessageId: 레코드에 포함된 메시지의 ID
  • PulsarProperties-*: 각 레코드 프로퍼티는 프로퍼티 이름 앞에 PulsarProperties-를 붙여 전달돼요.

구성 (Configuration)

HTTP sink 커넥터의 구성에는 다음과 같은 프로퍼티가 있어요.

프로퍼티 (Property)

이름 타입 필수 기본값 설명
url String false http://localhost HTTP 서버의 URL이에요.
headers Map false 빈 맵 각 요청에 추가되는 기본 헤더 목록이에요.

예제 (Example)

HTTP sink 커넥터를 사용하기 전에 다음 방법 중 하나로 구성 파일을 만들어야 해요.

  • JSON
{
   "configs": {
      "url": "http://my-endpoint.acme.com/api/ingest",
      "headers": {
         "Authentication": "xxxxx"
      }
   }
}
  • YAML
configs:
    url: "http://my-endpoint.acme.com/api/ingest"
    headers:
        Authentication: xxxxx

더 알아보기 (Learn more)