hi， Is that what you mean？ See : https://issues.apache.org/jira/browse/FLINK-8500?page=com.atlassian.jira.plugin.system.issuetabpanels%3Acomment-tabpanel&focusedCommentId=16377145#comment-16377145 <https://issues.apache.org/jira/browse/FLINK-8500?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16377145#comment-16377145>
Best Ben > On 30 Mar 2018, at 12:23 PM, Navneeth Krishnan <reachnavnee...@gmail.com> > wrote: > > Hi, > > Is there way to get the kafka timestamp in deserialization schema? All > records are written to kafka with timestamp and I would like to set that > timestamp to every record that is ingested. Thanks.
