[
https://issues.apache.org/jira/browse/BEAM-1514?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Xu Mingmin updated BEAM-1514:
-----------------------------
Comment: was deleted
(was: [~davor], can I have your help on how to setup the multiple version test?
I'm not quire familiar with Beam's test settings.
Now I can pass junit tests locally, with 'clean verify
-Dkafka.clients.version=0.10.1.1' and 'clean verify
-Dkafka.clients.version=0.9.0.1'. Doubt do I need to change .travis.yml? )
> change default timestamp in KafkaIO
> -----------------------------------
>
> Key: BEAM-1514
> URL: https://issues.apache.org/jira/browse/BEAM-1514
> Project: Beam
> Issue Type: Improvement
> Components: sdk-java-extensions
> Reporter: Xu Mingmin
> Assignee: Xu Mingmin
>
> When user use Kafka 0.10, the field 'timestamp' from Kafka should be used as
> the default event timestamp.
--
This message was sent by Atlassian JIRA
(v6.3.15#6346)
