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)
