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 e31f27f51c7ca413c7637d71d5c717af6a54281e Merge: 8345991 585547a Author: Ismaël Mejía <ieme...@gmail.com> AuthorDate: Wed May 23 22:29:31 2018 +0200 Merge pull request #5422 from timrobertson100/BEAM-4347 [BEAM-4347] Enforce ErrorProne analysis in kafka IO sdks/java/io/kafka/build.gradle | 4 +++- .../apache/beam/sdk/io/kafka/KafkaExactlyOnceSink.java | 12 ++++++++++-- .../main/java/org/apache/beam/sdk/io/kafka/KafkaIO.java | 1 + .../apache/beam/sdk/io/kafka/KafkaUnboundedReader.java | 15 ++++++++++----- .../java/org/apache/beam/sdk/io/kafka/KafkaWriter.java | 2 ++ .../kafka/CustomTimestampPolicyWithLimitedDelayTest.java | 2 +- .../java/org/apache/beam/sdk/io/kafka/KafkaIOTest.java | 12 +++++++----- .../apache/beam/sdk/io/kafka/KafkaRecordCoderTest.java | 3 ++- 8 files changed, 36 insertions(+), 15 deletions(-) -- To stop receiving notification emails like this one, please contact ieme...@apache.org.