Eno Thereska created KAFKA-5302: ----------------------------------- Summary: Improve exception handling on streams client (communication with brokers) Key: KAFKA-5302 URL: https://issues.apache.org/jira/browse/KAFKA-5302 Project: Kafka Issue Type: Sub-task Components: streams Affects Versions: 0.11.0.0 Reporter: Eno Thereska Assignee: Eno Thereska
These are exceptions in StreamsKafkaClient.java. 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)