This is an automated email from the ASF dual-hosted git repository.
aromanenko pushed a commit to branch master
in repository https://gitbox.apache.org/repos/asf/beam.git
commit d309c1b7c39ba78aa0cbd5cad9cc7a256e3caa9f
Merge: af8559d 8babe39
Author: Alexey Romanenko <33895511+aromanenko-...@users.noreply.github.com>
AuthorDate: Wed Mar 25 14:40:30 2020 +0100
Merge pull request #11099: [BEAM-9420] Configurable timeout for blocking
kafka API call(s)
.../java/org/apache/beam/sdk/io/kafka/KafkaIO.java | 8 ++++
.../beam/sdk/io/kafka/KafkaUnboundedReader.java | 48 ++++++++++++++++------
.../org/apache/beam/sdk/io/kafka/KafkaIOTest.java | 40 ++++++++++++++++--
3 files changed, 80 insertions(+), 16 deletions(-)
