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(-)