create_topic_with_schema
Create Kafka topics with configurable formats and schemas for structured data streaming. Define partitions, replication, and data formats like AVRO or JSON.
Instructions
Creates a new Kafka topic with optional format and schema configuration.
Args: environment: The environment name. name: Topic name. partitions: Number of partitions (default: 1). replication: Replication factor (default: 1). configs: Topic configurations. key_format: Key format (AVRO, JSON, CSV, XML, INT, LONG, STRING, BYTES, etc.). key_schema: Key schema (required for AVRO, JSON, CSV, XML). value_format: Value format. value_schema: Value schema.
Returns: Creation result.
Input Schema
| Name | Required | Description | Default |
|---|---|---|---|
| environment | Yes | ||
| name | Yes | ||
| partitions | No | ||
| replication | No | ||
| configs | No | ||
| key_format | No | ||
| key_schema | No | ||
| value_format | No | ||
| value_schema | No |
Output Schema
| Name | Required | Description | Default |
|---|---|---|---|
No arguments | |||