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)