Feature request: Kafka record timestamp column in Kafka Source Connector

ArroyoSystems / arroyo

Distributed stream processing engine in Rust

https://arroyo.dev

Apache License 2.0

3.81k stars 223 forks source link

Feature request: Kafka record timestamp column in Kafka Source Connector #631

Closed Wrekkers closed 4 weeks ago

Wrekkers commented 6 months ago

Currently the kafka record timestamp is used in Arroyo for default event_time purposes. Need to implement a feature wherein one would be able to access the record timestamp in Arroyo SQL as a column value. Can reserve a keyword to implement the same.