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

Posted to issues@flink.apache.org by "Robert Metzger (JIRA)" <ji...@apache.org> on 2016/03/22 16:26:25 UTC

[jira] [Resolved] (FLINK-2256) Handling Broker failures on the KafkaSink side

     [ https://issues.apache.org/jira/browse/FLINK-2256?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ]

Robert Metzger resolved FLINK-2256.
-----------------------------------
    Resolution: Fixed

Resolved in FLINK-3368

> Handling Broker failures on the KafkaSink side
> ----------------------------------------------
>
>                 Key: FLINK-2256
>                 URL: https://issues.apache.org/jira/browse/FLINK-2256
>             Project: Flink
>          Issue Type: Improvement
>          Components: Kafka Connector, Streaming Connectors
>    Affects Versions: 0.10.0
>            Reporter: Márton Balassi
>
> Currently instead of looking for a new Broker the sink throws an exception and thus cancels the job if the Broker failes. Assuming that the job has execution retries left and an available Broker to write to the job comes back, finds the Broker and continues. 



--
This message was sent by Atlassian JIRA
(v6.3.4#6332)