ncloud_datastream_create_connector
Create an Object Storage sink connector for a Data Stream topic. Use dry-run mode to preview the configuration before applying.
Instructions
Create a connector (Object Storage sink) for a Data Stream topic. Only one connector per topic. Use dryRun=true to preview.
Tool call template
Replace each placeholder with a value matching the input schema. Only required parameters are included; add optional parameters as needed.
{
"id": 1,
"jsonrpc": "2.0",
"method": "tools/call",
"params": {
"arguments": {
"topicId": "<topicId>",
"consumerSpec": "<consumerSpec>",
"location": "<location>",
"includeTopicInPath": "<includeTopicInPath>",
"dateFormat": "<dateFormat>",
"roleNrn": "<roleNrn>"
},
"name": "ncloud_datastream_create_connector"
}
}Input Schema
| Name | Required | Description | Default |
|---|---|---|---|
| dryRun | No | If true, preview without creating | |
| roleNrn | Yes | NRN of the Data Stream service role for connector access | |
| topicId | Yes | Topic ID to create connector for | |
| location | Yes | Storage path in s3a://{bucket}/{path} format | |
| dateFormat | Yes | Date format for sub-path: NONE, YEAR, MONTH, DAY, HOUR | |
| exportType | No | Connector type (currently only OBJECT_STORAGE) | OBJECT_STORAGE |
| flushCount | No | Messages per file (default: 5000) | |
| schemaType | No | Message value serialization (default: STRING) | |
| description | No | Connector description (max 200 chars) | |
| consumerSpec | Yes | Consumer spec: SMALL (1 container, 250KB/s per partition) or MEDIUM (2 containers, 500KB/s per partition) | |
| flushInterval | No | File creation interval in minutes (default: 10) | |
| includeTopicInPath | Yes | Whether to create topic name directory in storage path |