From d7b57d3058f589d445886fc04211e7caf62ce04c Mon Sep 17 00:00:00 2001 From: xiangying <1984997880@qq.com> Date: Wed, 26 Jul 2023 13:03:09 +0800 Subject: [PATCH 1/2] [optimize][transaction]Add log when can't send TcClientConnectRequest to broker. --- .../apache/pulsar/client/impl/TransactionMetaStoreHandler.java | 2 ++ 1 file changed, 2 insertions(+) diff --git a/pulsar-client/src/main/java/org/apache/pulsar/client/impl/TransactionMetaStoreHandler.java b/pulsar-client/src/main/java/org/apache/pulsar/client/impl/TransactionMetaStoreHandler.java index ebbfca0c3cb3f..db9d5c750120d 100644 --- a/pulsar-client/src/main/java/org/apache/pulsar/client/impl/TransactionMetaStoreHandler.java +++ b/pulsar-client/src/main/java/org/apache/pulsar/client/impl/TransactionMetaStoreHandler.java @@ -167,6 +167,8 @@ public CompletableFuture connectionOpened(ClientCnx cnx) { return null; }); } else { + LOG.warn("Can not Connect to the transaction coordinator because the protocol version {} is " + + "lower than 19", cnx.getRemoteEndpointProtocolVersion()); registerToConnection(cnx); future.complete(null); } From 8ebfd7704bf24bc62b275a01cf51e8ba8de70162 Mon Sep 17 00:00:00 2001 From: xiangying <1984997880@qq.com> Date: Sun, 30 Jul 2023 01:13:38 +0800 Subject: [PATCH 2/2] fix --- .../apache/pulsar/client/impl/TransactionMetaStoreHandler.java | 2 +- 1 file changed, 1 insertion(+), 1 deletion(-) diff --git a/pulsar-client/src/main/java/org/apache/pulsar/client/impl/TransactionMetaStoreHandler.java b/pulsar-client/src/main/java/org/apache/pulsar/client/impl/TransactionMetaStoreHandler.java index db9d5c750120d..0b5174a015118 100644 --- a/pulsar-client/src/main/java/org/apache/pulsar/client/impl/TransactionMetaStoreHandler.java +++ b/pulsar-client/src/main/java/org/apache/pulsar/client/impl/TransactionMetaStoreHandler.java @@ -167,7 +167,7 @@ public CompletableFuture connectionOpened(ClientCnx cnx) { return null; }); } else { - LOG.warn("Can not Connect to the transaction coordinator because the protocol version {} is " + LOG.warn("Can not connect to the transaction coordinator because the protocol version {} is " + "lower than 19", cnx.getRemoteEndpointProtocolVersion()); registerToConnection(cnx); future.complete(null);