You are viewing a plain text version of this content. The canonical link for it is here.

Posted to commits@beam.apache.org by ie...@apache.org on 2018/04/23 19:11:20 UTC

[beam] 01/01: Merge pull request #5111: [BEAM-4038] Support Kafka Headers in KafkaIO

This is an automated email from the ASF dual-hosted git repository.

iemejia pushed a commit to branch master
in repository https://gitbox.apache.org/repos/asf/beam.git

commit e6681e8aac364b11304fdd4a85642a89307eeaee
Merge: fdb051e d249621
Author: Ismaël Mejía <ie...@gmail.com>
AuthorDate: Mon Apr 23 21:11:11 2018 +0200

    Merge pull request #5111: [BEAM-4038] Support Kafka Headers in KafkaIO

 .../org/apache/beam/sdk/io/kafka/ConsumerSpEL.java | 16 +++++++++
 .../org/apache/beam/sdk/io/kafka/KafkaRecord.java  | 21 ++++++++++--
 .../apache/beam/sdk/io/kafka/KafkaRecordCoder.java | 35 +++++++++++++++++++
 .../beam/sdk/io/kafka/KafkaUnboundedReader.java    |  3 +-
 .../CustomTimestampPolicyWithLimitedDelayTest.java |  6 ++--
 .../beam/sdk/io/kafka/KafkaRecordCoderTest.java    | 39 ++++++++++++++++++++++
 6 files changed, 114 insertions(+), 6 deletions(-)

-- 
To stop receiving notification emails like this one, please contact
iemejia@apache.org.