register_kafka_table
Registers a Kafka topic as a queryable table in the Flink catalog using DDL, enabling real-time SQL queries on streaming data.
Instructions
Register a Kafka table in the Flink catalog using DDL (makes it queryable).
Input Schema
| Name | Required | Description | Default |
|---|---|---|---|
| topic | Yes | ||
| catalog | No | ssb | |
| database | No | ssb_default | |
| table_name | Yes | ||
| schema_fields | No | ||
| use_ssb_prefix | No |
Output Schema
| Name | Required | Description | Default |
|---|---|---|---|
| result | Yes |