Skip to main content

HTTTP sink connector


You can download all the Pulsar connectors on download page.

The HTTP sink connector pulls the records from Pulsar topics and makes a POST request to a configurable HTTP URL (webhook).

The body of the HTTP request is the JSON representation of the record value. The header Content-Type: application/json is added to the HTTP request.

Some other HTTP headers are added to the HTTP request:

  • PulsarTopic: the topic of the record
  • PulsarKey: the key of the record
  • PulsarEventTime: the event time of the record
  • PulsarPublishTime: the publish time of the record
  • PulsarMessageId: the ID of the message contained in the record
  • PulsarProperties-*: each record property is passed with the property name prefixed by PulsarProperties-


The configuration of the HTTP sink connector has the following properties.


urlStringfalsehttp://localhostThe URL of the HTTP server
headersMapfalseempty mapThe list of default headers added to each request


Before using the HTTP sink connector, you need to create a configuration file through one of the following methods.

  • JSON

    "configs": {
    "url": "",
    "headers": {
    "Authentication": "xxxxx"
  • YAML

    url: ""
    Authentication: xxxxx