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 9babd2ad419ec..02429d2791855 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 @@ -156,6 +156,7 @@ private boolean isValidStateForReconnection() { switch (state) { case Uninitialized: case Connecting: + case RegisteringSchema: case Ready: // Ok return true;