@@ -31,15 +31,23 @@ inline bool isResultRetryable(Result result) {
3131 return true ;
3232 }
3333
34- static const std::unordered_set<Result> fatalResults{
35- ResultConnectError, ResultAuthenticationError,
36- ResultAuthorizationError, ResultInvalidUrl,
37- ResultInvalidConfiguration, ResultIncompatibleSchema,
38- ResultTopicNotFound, ResultOperationNotSupported,
39- ResultNotAllowedError, ResultChecksumError,
40- ResultCryptoError, ResultConsumerAssignError,
41- ResultProducerBusy, ResultConsumerBusy,
42- ResultLookupError, ResultTooManyLookupRequestException};
34+ static const std::unordered_set<Result> fatalResults{ResultConnectError,
35+ ResultTimeout,
36+ ResultAuthenticationError,
37+ ResultAuthorizationError,
38+ ResultInvalidUrl,
39+ ResultInvalidConfiguration,
40+ ResultIncompatibleSchema,
41+ ResultTopicNotFound,
42+ ResultOperationNotSupported,
43+ ResultNotAllowedError,
44+ ResultChecksumError,
45+ ResultCryptoError,
46+ ResultConsumerAssignError,
47+ ResultProducerBusy,
48+ ResultConsumerBusy,
49+ ResultLookupError,
50+ ResultTooManyLookupRequestException};
4351 return fatalResults.find (result) == fatalResults.cend ();
4452}
4553
0 commit comments