Eno Thereska created KAFKA-5312: ----------------------------------- Summary: Improve exception handling for StreamsKafkaClient Key: KAFKA-5312 URL: https://issues.apache.org/jira/browse/KAFKA-5312 Project: Kafka Issue Type: Sub-task Components: streams Affects Versions: 0.11.0.0 Reporter: Eno Thereska Assignee: Eno Thereska
Currently throws either StreamsException or BrokerNotFoundException. Used by InternalTopicManager to create topics and get their metadata. Used by StreamPartitionAssignor. Currently InternalTopicManager retries a few times after catching an exception. A failure here is sent all the way up to the stream thread and will stop the streams pipeline. -- This message was sent by Atlassian JIRA (v6.3.15#6346)