@@ -31,26 +31,26 @@ inline bool isResultRetryable(Result result) {
3131 return true ;
3232 }
3333
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,
51- ResultProducerBlockedQuotaExceededException,
52- ResultProducerBlockedQuotaExceededError};
53- return fatalResults.find (result) == fatalResults.cend ();
34+ static const std::unordered_set<int > 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,
51+ ResultProducerBlockedQuotaExceededException,
52+ ResultProducerBlockedQuotaExceededError};
53+ return fatalResults.find (static_cast < int >( result) ) == fatalResults.cend ();
5454}
5555
5656} // namespace pulsar
0 commit comments