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

Posted to commits@beam.apache.org by ar...@apache.org on 2020/03/25 13:40:49 UTC

[beam] 01/01: Merge pull request #11099: [BEAM-9420] Configurable timeout for blocking kafka API call(s)

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 <33...@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(-)