pulsar icon indicating copy to clipboard operation
pulsar copied to clipboard

Use key story tls connect to broker,but IP change to 127.0.0.1 and connect failed

Open liliang950210 opened this issue 3 years ago • 1 comments

when use key store tls connect broker,while ip change to 127.0.0.1?

[pulsar-client-io-1-1] INFO org.apache.pulsar.client.impl.ConnectionPool - [[id: 0xdded1946, L:/10.25.xxx.xx:58107 - R:/7.xx.xx.xx:21852]] Connected to server [pulsar-client-io-1-1] INFO org.apache.pulsar.client.impl.ConsumerStatsRecorderImpl - Starting Pulsar consumer status recorder with config: { "topicNames" : [ "persistent://public/default/test-auto" ], "topicsPattern" : null, "subscriptionName" : "my-sub4", "subscriptionType" : "Failover", "subscriptionMode" : "Durable", "receiverQueueSize" : 1000, "acknowledgementsGroupTimeMicros" : 100000, "negativeAckRedeliveryDelayMicros" : 60000000, "maxTotalReceiverQueueSizeAcrossPartitions" : 50000, "consumerName" : null, "ackTimeoutMillis" : 0, "tickDurationMillis" : 1000, "priorityLevel" : 0, "maxPendingChuckedMessage" : 10, "autoAckOldestChunkedMessageOnQueueFull" : false, "expireTimeOfIncompleteChunkedMessageMillis" : 60000, "cryptoFailureAction" : "FAIL", "properties" : { }, "readCompacted" : true, "subscriptionInitialPosition" : "Latest", "patternAutoDiscoveryPeriod" : 60, "regexSubscriptionMode" : "PersistentOnly", "deadLetterPolicy" : null, "retryEnable" : false, "autoUpdatePartitions" : true, "autoUpdatePartitionsIntervalSeconds" : 60, "replicateSubscriptionState" : false, "resetIncludeHead" : false, "keySharedPolicy" : null, "batchIndexAckEnabled" : false } [pulsar-client-io-1-1] INFO org.apache.pulsar.client.impl.ConsumerStatsRecorderImpl - Pulsar client config: { "serviceUrl" : "pulsar+ssl://7.212.38.237:xxxx", "authPluginClassName" : null, "operationTimeoutMs" : 30000, "statsIntervalSeconds" : 60, "numIoThreads" : 1, "numListenerThreads" : 1, "connectionsPerBroker" : 1, "useTcpNoDelay" : true, "useTls" : true, "tlsTrustCertsFilePath" : "", "tlsAllowInsecureConnection" : false, "tlsHostnameVerificationEnable" : false, "concurrentLookupRequest" : 5000, "maxLookupRequest" : 50000, "maxLookupRedirects" : 20, "maxNumberOfRejectedRequestPerConnection" : 50, "keepAliveIntervalSeconds" : 30, "connectionTimeoutMs" : 10000, "requestTimeoutMs" : 60000, "initialBackoffIntervalNanos" : 100000000, "maxBackoffIntervalNanos" : 60000000000, "listenerName" : null, "useKeyStoreTls" : true, "sslProvider" : null, "tlsTrustStoreType" : "JKS", "tlsTrustStorePath" : "D:\tmp\ssl\cloudSop\trust.jks", "tlsTrustStorePassword" : "xxxxxxxxxx", "tlsCiphers" : [ ], "tlsProtocols" : [ ], "proxyServiceUrl" : null, "proxyProtocol" : null, "enableTransaction" : false } [pulsar-client-io-1-1] WARN org.apache.pulsar.client.impl.ConnectionPool - Failed to open connection to 127.0.0.1:21852 : org.apache.pulsar.shade.io.netty.channel.AbstractChannel$AnnotatedConnectException: Connection refused: no further information: /127.0.0.1:21852 [pulsar-client-io-1-1] WARN org.apache.pulsar.client.impl.ConnectionHandler - [persistent://public/default/test-auto] [my-sub4] Error connecting to broker: org.apache.pulsar.client.api.PulsarClientException: java.util.concurrent.CompletionException: org.apache.pulsar.shade.io.netty.channel.AbstractChannel$AnnotatedConnectException: Connection refused: no further information: /127.0.0.1:21852 [pulsar-client-io-1-1] WARN org.apache.pulsar.client.impl.ConnectionHandler - [persistent://public/default/test-auto] [my-sub4] Could not get connection to broker: org.apache.pulsar.client.api.PulsarClientException: java.util.concurrent.CompletionException: org.apache.pulsar.shade.io.netty.channel.AbstractChannel$AnnotatedConnectException: Connection refused: no further information: /127.0.0.1:21852 -- Will try again in 0.1 s [pulsar-timer-5-1] INFO org.apache.pulsar.client.impl.ConnectionHandler - [persistent://public/default/test-auto] [my-sub4] Reconnecting after connection was closed [pulsar-client-io-1-1] WARN org.apache.pulsar.client.impl.ConnectionPool - Failed to open connection to 127.0.0.1:21852 : org.apache.pulsar.shade.io.netty.channel.AbstractChannel$AnnotatedConnectException: Connection refused: no further information: /127.0.0.1:21852 [pulsar-client-io-1-1] WARN org.apache.pulsar.client.impl.ConnectionHandler - [persistent://public/default/test-auto] [my-sub4] Error connecting to broker: org.apache.pulsar.client.api.PulsarClientException: java.util.concurrent.CompletionException: org.apache.pulsar.shade.io.netty.channel.AbstractChannel$AnnotatedConnectException: Connection refused: no further information: /127.0.0.1:21852 [pulsar-client-io-1-1] WARN org.apache.pulsar.client.impl.ConnectionHandler - [persistent://public/default/test-auto] [my-sub4] Could not get connection to broker: org.apache.pulsar.client.api.PulsarClientException: java.util.concurrent.CompletionException: org.apache.pulsar.shade.io.netty.channel.AbstractChannel$AnnotatedConnectException: Connection refused: no further information: /127.0.0.1:21852 -- Will try again in 0.191 s [pulsar-timer-5-1] INFO org.apache.pulsar.client.impl.ConnectionHandler - [persistent://public/default/test-auto] [my-sub4] Reconnecting after connection was closed

liliang950210 avatar Aug 08 '22 01:08 liliang950210

I found this problem. I set advertisedAddress=127.0.0.1 to 127.0.0.1 in the broker, but bindAddress is not configured. As a result, the broker listens on the entire network and external systems can access the service, but an error is reported during the connection. Change the value of advertisedAddress to the corresponding IP address.

liliang950210 avatar Aug 09 '22 03:08 liliang950210