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);
}