beam-commits mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From "Xu Mingmin (JIRA)" <>
Subject [jira] [Issue Comment Deleted] (BEAM-1514) change default timestamp in KafkaIO
Date Thu, 23 Feb 2017 01:18:45 GMT


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=' and
'clean verify -Dkafka.clients.version='. Doubt do I need to change .travis.yml? )

> change default timestamp in KafkaIO
> -----------------------------------
>                 Key: BEAM-1514
>                 URL:
>             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

View raw message