diff --git a/pulsar-client/src/main/java/org/apache/pulsar/client/impl/ConnectionHandler.java b/pulsar-client/src/main/java/org/apache/pulsar/client/impl/ConnectionHandler.java index 8fb7ab41d8867..13de530eaf848 100644 --- a/pulsar-client/src/main/java/org/apache/pulsar/client/impl/ConnectionHandler.java +++ b/pulsar-client/src/main/java/org/apache/pulsar/client/impl/ConnectionHandler.java @@ -152,6 +152,7 @@ private boolean isValidStateForReconnection() { switch (state) { case Uninitialized: case Connecting: + case RegisteringSchema: case Ready: // Ok return true;