You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@beam.apache.org by ch...@apache.org on 2019/05/09 18:12:41 UTC
[beam] branch master updated (2d671a6 -> 1ac8e7a)
This is an automated email from the ASF dual-hosted git repository.
chamikara pushed a change to branch master
in repository https://gitbox.apache.org/repos/asf/beam.git.
from 2d671a6 Moving to 2.14.0-SNAPSHOT on master branch.
add 477a2a0 [BEAM-7143] adding withConsumerConfigUpdates
add 1ac8e7a Merge pull request #8398: [BEAM-7143] adding withConsumerConfigUpdates
No new revisions were added by this update.
Summary of changes:
.../ResumeFromCheckpointStreamingTest.java | 2 +-
.../sql/meta/provider/kafka/BeamKafkaTable.java | 4 +--
.../java/org/apache/beam/sdk/io/kafka/KafkaIO.java | 33 ++++++++++++++++++----
.../org/apache/beam/sdk/io/kafka/KafkaIOTest.java | 9 +++---
4 files changed, 36 insertions(+), 12 deletions(-)