You are viewing a plain text version of this content. The canonical link for it is here.

Posted to commits@beam.apache.org by tv...@apache.org on 2020/07/07 04:19:41 UTC

[beam] 01/01: [BEAM-10410] Move Kafka directly to io submodule.

This is an automated email from the ASF dual-hosted git repository.

tvalentyn pushed a commit to branch release-2.23.0
in repository https://gitbox.apache.org/repos/asf/beam.git

commit c1766b2ce43f2ad639724a9a52e3cb0bb815dca3
Merge: 7a8ec98 c1d658a
Author: tvalentyn <tv...@users.noreply.github.com>
AuthorDate: Mon Jul 6 21:19:11 2020 -0700

    [BEAM-10410] Move Kafka directly to io submodule.

 sdks/python/apache_beam/io/external/kafka.py       | 205 +--------------------
 .../io/external/xlang_kafkaio_it_test.py           |   4 +-
 sdks/python/apache_beam/io/{external => }/kafka.py |   0
 .../runners/portability/flink_runner_test.py       |   4 +-
 4 files changed, 13 insertions(+), 200 deletions(-)