beam-commits mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From aromane...@apache.org
Subject [beam] 01/01: Merge pull request #11099: [BEAM-9420] Configurable timeout for blocking kafka API call(s)
Date Wed, 25 Mar 2020 13:40:49 GMT
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-dev@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(-)


Mime
View raw message