feat: optionally use Kafka timestamps as designated timestamps

questdb / kafka-questdb-connector

QuestDB connector for Kafka.

https://github.com/questdb/kafka-questdb-connector/releases/

Apache License 2.0

31 stars 5 forks source link

feat: optionally use Kafka timestamps as designated timestamps #8

Closed jerrinot closed 1 year ago

jerrinot commented 1 year ago

This PR makes it possible to use timestamps from Kafka record metadata as a designated timestamp in QuestDB.

It introduces a new boolean configuration option: timestamp.kafka.native It's false by default and when enabled then the connector with use timestamps from Kafka records metadata as designated timestamps. This option is mutually exclusive with timestamp.field.name.