ncloud_datastream_create_connector
Create a Data Stream topic connector to sink data to Object Storage. Configure consumer spec, storage path, date format, and use dryRun to preview.
Instructions
Create a connector (Object Storage sink) for a Data Stream topic. Only one connector per topic. Use dryRun=true to preview.
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 |