| Parameter | Type | Required | Default value | Description |
|---|---|---|---|---|
| access.id | String | Yes | None | The access ID of the DataHub instance. |
| access.key | String | Yes | None | The access key of the DataHub instance. |
| batch.size | Integer | No | 20 | The batch size. Default value: 20. |
| binary.enable | Boolean | No | true | Specifies whether to enable binary write. Default value: true. |
| connection.timeout.ms | Integer | No | 10000 | The timeout period for connecting to the DataHub instance. |
| endpoint | String | Yes | None | The endpoint of the DataHub instance. |
| fields.optional | List | No | rowid,__pk_increment | The optional fields. |
| linger.ms | Long | No | 1 | The time to wait before sending a batch. |
| protocol | String | No | TUPLE | The protocol used for writing data to downstream nodes. |
| project | String | Yes | None | The project name corresponding to the DataHub instance. |
| read.timeout.ms | Integer | No | 3000 | The timeout period for reading data. |
| sequence.enable | Boolean | No | false | Specifies whether to enable sequences. Default value: false. |
| sequence.ignore.local | Boolean | No | false | Specify whether to ignore sequences. Default value: false. |
| sequence.start.timestamp | Long | No | 0 | The timestamp when the sequence starts incrementing. This parameter is valid when sequence.enable is set to true. Default value: 0. |
| shards | String | No | None | The list of shards to which messages are sent by default. |
| shard.fields | List | No | None | The sharding columns. |
| topic | String | Yes | None | The topic of the DataHub instance. |
Parameters of a destination DataHub instance
share
Previous topic