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

[Shang Yuanchun (Jira)]

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)