This is an automated email from the ASF dual-hosted git repository.
iemejia pushed a change to branch master
in repository https://gitbox.apache.org/repos/asf/beam.git.
from 8345991 Merge pull request #5455: Fix build with Maven (Again!)
add 41f75b1 [BEAM-4347] Enforce ErrorProne analysis in kafka IO
add aa25105 [BEAM-4347] Improve ErrorProne analysis in kafka IO
add 2750999 [BEAM-4347] Minor changes following PR review
add 585547a [BEAM-4347] Correction of typo following PR review
new e31f27f Merge pull request #5422 from timrobertson100/BEAM-4347
The 1 revisions listed above as "new" are entirely new to this
repository and will be described in separate emails. The revisions
listed as "add" were already present in the repository and have only
been added to this reference.
Summary of changes:
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.
