This is an automated email from the ASF dual-hosted git repository.

technoboy pushed a commit to branch branch-2.10
in repository https://gitbox.apache.org/repos/asf/pulsar.git


The following commit(s) were added to refs/heads/branch-2.10 by this push:
     new 40d018ff763 [improve][txn]Add log when can't send 
TcClientConnectRequest to broker. (#20880)
40d018ff763 is described below

commit 40d018ff763955e39a4bfa6f011e2e996f04fc2f
Author: Xiangying Meng <[email protected]>
AuthorDate: Mon Jul 31 10:10:35 2023 +0800

    [improve][txn]Add log when can't send TcClientConnectRequest to broker. 
(#20880)
    
    Main Issue: https://github.com/apache/pulsar/issues/20851
    ### Motivation
    When the Proto version does not allow us to send TcClientConnectRequest to 
the broker, we should add a log to debug it.
    
    ### Modifications
    
    Add a waining log.
---
 .../java/org/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 56443709bf3..954375919d8 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 class TransactionMetaStoreHandler extends 
HandlerState
                     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);
             }

Reply via email to