From 2f0c9805db79465038067ddf8e3b22aeec39674b Mon Sep 17 00:00:00 2001 From: Michael Marshall Date: Fri, 12 Nov 2021 22:03:07 -0600 Subject: [PATCH] [Java Client] Let producer reconnect for state RegisteringSchema --- .../java/org/apache/pulsar/client/impl/ConnectionHandler.java | 1 + 1 file changed, 1 insertion(+) 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;