ground_kafka_topic
Discover a Kafka topic's schema by sampling its messages, returning a schema plus sample rows ready for Flink job generation.
Instructions
Discover a Kafka topic's schema by sampling its messages, returning a schema + sample rows ready to pass to generate_flink_job. Use when the user references a real topic and you don't have its schema. Requires a reachable Kafka broker with the topic populated.
Input Schema
| Name | Required | Description | Default |
|---|---|---|---|
| topic | Yes | ||
| bootstrap | No | Broker (default localhost:9092). | |
| event_time | Yes | Name of the event-time column. | |
| sample_size | No | ||
| watermark_delay_seconds | No |