Fix wrong check

BewareMyPower · BewareMyPower · commit cc5d8b02f751 · 2024-01-31T15:53:43.000+08:00
diff --git a/lib/ClientConnection.cc b/lib/ClientConnection.cc
@@ -1475,7 +1475,7 @@ void ClientConnection::checkServerError(ServerError error, const std::string& me
             // See
             // https://github.com/apache/pulsar/blob/1952f94769d9dc80908d159be6e6ce1ff48b83fb/pulsar-broker/src/main/java/org/apache/pulsar/broker/lookup/TopicLookupBase.java#L334
             // These errors should be retryable and we should not close the connection
-            if (message.find("Failed to lookup") != std::string::npos) {
+            if (message.find("Failed to lookup") == std::string::npos) {
                 close(ResultDisconnected);
             }
             break;

Original file line number	Diff line number	Diff line change
`@@ -1475,7 +1475,7 @@ void ClientConnection::checkServerError(ServerError error, const std::string& me`
`1475`	`1475`	`// See`
`1476`	`1476`	`// https://github.com/apache/pulsar/blob/1952f94769d9dc80908d159be6e6ce1ff48b83fb/pulsar-broker/src/main/java/org/apache/pulsar/broker/lookup/TopicLookupBase.java#L334`
`1477`	`1477`	`// These errors should be retryable and we should not close the connection`
`1478`		`- if (message.find("Failed to lookup") != std::string::npos) {`
	`1478`	`+ if (message.find("Failed to lookup") == std::string::npos) {`
`1479`	`1479`	`close(ResultDisconnected);`
`1480`	`1480`	`}`
`1481`	`1481`	`break;`