[beam] 01/01: Merge pull request #6421 from rangadi/cherrypick

[ccy]

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

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

commit e14c385ef1d1cbdd7c5d79dc6e135f1aa494c39c
Merge: f29e74a d34d3af
Author: Charles Chen <charlesccyc...@users.noreply.github.com>
AuthorDate: Mon Sep 17 20:07:03 2018 -0700

    Merge pull request #6421 from rangadi/cherrypick
    
    [cherrypick d34d3af068] [BEAM-5375] KafkaIO : Handle runtime exceptions 
while fetching from Kafka better.  (#6391)

 .../beam/sdk/io/kafka/KafkaUnboundedReader.java    | 55 +++++++++++++---------
 .../org/apache/beam/sdk/io/kafka/KafkaIOTest.java  | 40 ++++++++++++++++
 2 files changed, 72 insertions(+), 23 deletions(-)