fetch_by_time
Fetch Kafka messages starting from the first offset at or after a given Unix timestamp in milliseconds. Specify topic, optional partition, and result limit to read historical data.
Instructions
Fetch messages from the first offset at or after a timestamp.
Input Schema
| Name | Required | Description | Default |
|---|---|---|---|
| topic | Yes | Kafka topic name. | |
| max_results | No | ||
| partition_id | No | Partition to read from, or -1 for all partitions. | |
| timestamp_ms | Yes | Unix epoch time in milliseconds. |
Output Schema
| Name | Required | Description | Default |
|---|---|---|---|
| result | Yes |