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

Posted to dev@flink.apache.org by "Márton Balassi (JIRA)" <ji...@apache.org> on 2015/06/22 14:05:00 UTC

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

Márton Balassi created FLINK-2256:
-------------------------------------

             Summary: 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
            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)