You are viewing a plain text version of this content. The canonical link for it is here.
Posted to issues@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)