# Http

> Http sink connector

### Key Features[​](https://seatunnel.apache.org/docs/2.3.7/connector-v2/sink/Http#key-features) <a href="#key-features" id="key-features"></a>

* [ ] &#x20;exactly-once
* [ ] &#x20;cdc
* [x] &#x20;support multiple table write

### Description[​](https://seatunnel.apache.org/docs/2.3.7/connector-v2/sink/Http#description) <a href="#description" id="description"></a>

Used to launch web hooks using data.

> For example, if the data from upstream is \[`age: 12, name: tyrantlucifer`], the body content is the following: `{"age": 12, "name": "tyrantlucifer"}`

**Tips: Http sink only support `post json` webhook and the data from source will be treated as body content in web hook.**

### Sink Options[​](https://seatunnel.apache.org/docs/2.3.7/connector-v2/sink/Http#sink-options) <a href="#sink-options" id="sink-options"></a>

| Name                           | Type   | Required | Default | Description                                                                                                                                                          |
| ------------------------------ | ------ | -------- | ------- | -------------------------------------------------------------------------------------------------------------------------------------------------------------------- |
| url                            | String | Yes      | -       | Http request url                                                                                                                                                     |
| headers                        | Map    | No       | -       | Http headers                                                                                                                                                         |
| retry                          | Int    | No       | -       | The max retry times if request http return to `IOException`                                                                                                          |
| retry\_backoff\_multiplier\_ms | Int    | No       | 100     | The retry-backoff times(millis) multiplier if request http failed                                                                                                    |
| retry\_backoff\_max\_ms        | Int    | No       | 10000   | The maximum retry-backoff times(millis) if request http failed                                                                                                       |
| connect\_timeout\_ms           | Int    | No       | 12000   | Connection timeout setting, default 12s.                                                                                                                             |
| socket\_timeout\_ms            | Int    | No       | 60000   | Socket timeout setting, default 60s.                                                                                                                                 |
| common-options                 |        | No       | -       | Sink plugin common parameters, please refer to [Sink Common Options](/data-integration-with-nexus/nexus-elements/connectors/sink/sink-common-options.md) for details |

### Example[​](https://seatunnel.apache.org/docs/2.3.7/connector-v2/sink/Http#example) <a href="#example" id="example"></a>

simple:

```
Http {
    url = "http://localhost/test/webhook"
    headers {
        token = "9e32e859ef044462a257e1fc76730066"
    }
}
```

#### Multiple table[​](https://seatunnel.apache.org/docs/2.3.7/connector-v2/sink/Http#multiple-table) <a href="#multiple-table" id="multiple-table"></a>

**example1**[**​**](https://seatunnel.apache.org/docs/2.3.7/connector-v2/sink/Http#example1)

```
env {
  parallelism = 1
  job.mode = "STREAMING"
  checkpoint.interval = 5000
}

source {
  Mysql-CDC {
    base-url = "jdbc:mysql://127.0.0.1:3306/nexus"
    username = "root"
    password = "******"
    
    table-names = ["nexus.role","nexus.user","galileo.Bucket"]
  }
}

transform {
}

sink {
  Http {
    ...
    url = "http://localhost/test/${database_name}_test/${table_name}_test"
  }
}
```

**example2**[**​**](https://seatunnel.apache.org/docs/2.3.7/connector-v2/sink/Http#example2)

```
env {
  parallelism = 1
  job.mode = "BATCH"
}

source {
  Jdbc {
    driver = oracle.jdbc.driver.OracleDriver
    url = "jdbc:oracle:thin:@localhost:1521/XE"
    user = testUser
    password = testPassword

    table_list = [
      {
        table_path = "TESTSCHEMA.TABLE_1"
      },
      {
        table_path = "TESTSCHEMA.TABLE_2"
      }
    ]
  }
}

transform {
}

sink {
  Http {
    ...
    url = "http://localhost/test/${schema_name}_test/${table_name}_test"
  }
}
```


---

# Agent Instructions: Querying This Documentation

If you need additional information that is not directly available in this page, you can query the documentation dynamically by asking a question.

Perform an HTTP GET request on the current page URL with the `ask` query parameter:

```
GET https://docs.selfuel.digital/data-integration-with-nexus/nexus-elements/connectors/sink/http.md?ask=<question>
```

The question should be specific, self-contained, and written in natural language.
The response will contain a direct answer to the question and relevant excerpts and sources from the documentation.

Use this mechanism when the answer is not explicitly present in the current page, you need clarification or additional context, or you want to retrieve related documentation sections.