[
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)