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 2020/08/06 19:46:39 UTC

[beam] branch master updated (8d03dc6 -> 12dc669)

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 8d03dc6  Merge pull request #12471 [BEAM-9615] Add initial Schema to Go conversions.
     add a8a1f5a  [BEAM-10543] Add new parameters to Kafka Read cross language configuration
     add 2daf84d  [BEAM-10543] Add new parameters to python wrapper of Kafka Read
     add cf5c7ec  [BEAM-10543] Modify Kafka python cross-language integration test to use new parameters
     add fbf6e0a  [BEAM-10543] Run Kafka cross-language integration test in python postcommit suite instead of separate task
     add 12dc669  Merge pull request #12325: [BEAM-10543] Upgrade Kafka cross-language python tests

No new revisions were added by this update.

Summary of changes:
 build.gradle                                       |  2 -
 .../java/org/apache/beam/sdk/io/kafka/KafkaIO.java | 23 ++++++++-
 .../beam/sdk/io/kafka/KafkaIOExternalTest.java     | 14 ++++++
 .../io/external/xlang_kafkaio_it_test.py           | 56 +++++++++++++++-------
 sdks/python/apache_beam/io/kafka.py                | 50 +++++++++++--------
 sdks/python/test-suites/portable/common.gradle     | 36 ++------------
 6 files changed, 109 insertions(+), 72 deletions(-)