This is an automated email from the ASF dual-hosted git repository.
altay pushed a change to branch master
in repository https://gitbox.apache.org/repos/asf/beam.git.
from 5d07d9f Merge pull request #6276: [BEAM-5219] Make OutgoingMessage
public
add 9b85316 [BEAM-5375] KafkaIO : Handle runtime exceptions while
fetching from Kafka better. (#6391)
No new revisions were added by this update.
Summary of changes:
.../beam/sdk/io/kafka/KafkaUnboundedReader.java | 55 +++++++++++++---------
.../org/apache/beam/sdk/io/kafka/KafkaIOTest.java | 40 ++++++++++++++++
2 files changed, 72 insertions(+), 23 deletions(-)
