[GitHub] [beam] ihji commented on a change in pull request #11847: [BEAM-10125] adding cross-language KafkaIO integration test

ihji commented on a change in pull request #11847: URL: https://github.com/apache/beam/pull/11847#discussion_r432142814 ## File path: sdks/python/apache_beam/io/external/xlang_kafkaio_it_test.py ## @@ -0,0 +1,145 @@ +"""Integration test for Python cross-language pipelines for

[GitHub] [beam] ihji commented on a change in pull request #11847: [BEAM-10125] adding cross-language KafkaIO integration test

ihji commented on a change in pull request #11847: URL: https://github.com/apache/beam/pull/11847#discussion_r432142992 ## File path: sdks/python/apache_beam/io/external/xlang_kafkaio_it_test.py ## @@ -0,0 +1,145 @@ +"""Integration test for Python cross-language pipelines for

[GitHub] [beam] ihji commented on a change in pull request #11847: [BEAM-10125] adding cross-language KafkaIO integration test

ihji commented on a change in pull request #11847: URL: https://github.com/apache/beam/pull/11847#discussion_r432142695 ## File path: sdks/python/apache_beam/io/external/xlang_kafkaio_it_test.py ## @@ -0,0 +1,145 @@ +"""Integration test for Python cross-language pipelines for