[jira] [Commented] (CALCITE-3073) Support to consume from timestamp in KafkaAdapter

[Matt Wang (JIRA)]

    [ 
https://issues.apache.org/jira/browse/CALCITE-3073?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16857860#comment-16857860
 ] 

Matt Wang commented on CALCITE-3073:
------------------------------------

[~zhztheplayer] 👍 We can use `MSG_TIMESTAMP` field to define the end 
timestamp(I almost forgot it), it's not necessary to define `KAFKA_TIMESTAMP` 
reserved keyword. Just setting the start timestamp can satisfy the case of 
querying a specific range.

> Support to consume from timestamp in KafkaAdapter
> -------------------------------------------------
>
>                 Key: CALCITE-3073
>                 URL: https://issues.apache.org/jira/browse/CALCITE-3073
>             Project: Calcite
>          Issue Type: Improvement
>          Components: kafka-adapter
>            Reporter: Xu Mingmin
>            Assignee: Matt Wang
>            Priority: Major
>              Labels: pull-request-available
>          Time Spent: 3h 40m
>  Remaining Estimate: 0h
>
> Currently the KafkaAdapter consumes data from default 
> offset(latest/earliest/last_offset) and runs forever. With support of from/to 
> timestamp/offset, it's more flexible for users to query a specific range.



--
This message was sent by Atlassian JIRA
(v7.6.3#76005)