Details
-
Sub-task
-
Status: Resolved
-
Major
-
Resolution: Duplicate
-
0.11.0.0
-
None
-
None
Description
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.
Attachments
Issue Links
- duplicates
-
KAFKA-5302 Improve exception handling on streams client (communication with brokers)
- Resolved