[ https://issues.apache.org/jira/browse/CALCITE-3073?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16857871#comment-16857871 ]
Xu Mingmin commented on CALCITE-3073: ------------------------------------- Either field name is good to me, I do want to avoid the configuration in files. \{{MSG_TIMESTAMP}} is the name in the default converter, users may have their own. > 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)