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

Posted to commits@beam.apache.org by ti...@apache.org on 2019/05/06 19:15:39 UTC

[beam] branch master updated (04eb435 -> 67b49ce)

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

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


    from 04eb435  Merge pull request #8508: Refines categories to use `UsesTestStreamWithProcessingTime` in `TestStreamTests`
     add ffa5632  [BEAM-7216] reinstate checks for Kafka client methods
     add 67b49ce  Merge pull request #8503: [BEAM-7216] reinstate checks for Kafka client methods

No new revisions were added by this update.

Summary of changes:
 sdks/java/io/kafka/build.gradle                    |  1 +
 .../org/apache/beam/sdk/io/kafka/ConsumerSpEL.java |  7 ++--
 .../org/apache/beam/sdk/io/kafka/KafkaRecord.java  |  2 +-
 .../apache/beam/sdk/io/kafka/KafkaRecordCoder.java |  6 +--
 .../beam/sdk/io/kafka/KafkaUnboundedReader.java    |  2 +-
 .../beam/sdk/io/kafka/ProducerRecordCoder.java     | 25 +++++++-----
 .../beam/sdk/io/kafka/ProducerRecordCoderTest.java | 44 ++++++++++++++++++++--
 7 files changed, 65 insertions(+), 22 deletions(-)