GitHub user rgaur12 added a comment to the discussion: Connection timeout
working is not same as described in the clientBuilder[Bug]
creating the pulsar connection with invalid host IP/Broker URL which doesn't
exist and connection timeout 10 seconds.
While building the client it is taking more then 10 sec to throw exception then
given time in connection timeout and retrying to connect to broker.
` <CausedBy> TIBCO-BW-CORE-500051: Activity [PulsarProducer] fault.
<CausedBy> com.tibco.bw.palette.pulsar.runtime.fault.PulsarPluginException:
TIBCO-BW-PALETTE-PULSAR-500008: Exception occurred while sending a message
[java.util.concurrent.ExecutionException:
org.apache.pulsar.client.api.PulsarClientException:
java.util.concurrent.CompletionException:
org.apache.pulsar.shade.io.netty.channel.AbstractChannel$AnnotatedConnectException:
Connection refused: no further information:
pulsar://broker.example.com:6650/{"previous":[{"attempt":0,"error":"java.util.concurrent.CompletionException:
org.apache.pulsar.client.api.PulsarClientException:
java.util.concurrent.CompletionException:
org.apache.pulsar.shade.io.netty.channel.AbstractChannel$AnnotatedConnectException:
Connection refused: no further information:
pulsar://broker.example.com:6650/"},{"attempt":1,"error":"java.util.concurrent.CompletionException:
org.apache.pulsar.client.api.PulsarClientException:
java.util.concurrent.Completi
onException:
org.apache.pulsar.shade.io.netty.channel.AbstractChannel$AnnotatedConnectException:
Connection refused: no further information:
pulsar://broker.example.com:6650/"},{"attempt":2,"error":"java.util.concurrent.CompletionException:
org.apache.pulsar.client.api.PulsarClientException:
java.util.concurrent.CompletionException:
org.apache.pulsar.shade.io.netty.channel.AbstractChannel$AnnotatedConnectException:
Connection refused: no further information:
pulsar://broker.example.com:6650/"},{"attempt":3,"error":"java.util.concurrent.CompletionException:
org.apache.pulsar.client.api.PulsarClientException:
java.util.concurrent.CompletionException:
org.apache.pulsar.shade.io.netty.channel.AbstractChannel$AnnotatedConnectException:
Connection refused: no further information:
pulsar://broker.example.com:6650/"},{"attempt":4,"error":"java.util.concurrent.CompletionException:
org.apache.pulsar.client.api.PulsarClientException:
java.util.concurrent.CompletionException: org.apache.pulsar.
shade.io.netty.channel.AbstractChannel$AnnotatedConnectException: Connection
refused: no further information:
pulsar://broker.example.com:6650/"},{"attempt":5,"error":"java.util.concurrent.CompletionException:
org.apache.pulsar.client.api.PulsarClientException:
java.util.concurrent.CompletionException:
org.apache.pulsar.shade.io.netty.channel.AbstractChannel$AnnotatedConnectException:
Connection refused: no further information:
pulsar://broker.example.com:6650/"},{"attempt":6,"error":"java.util.concurrent.CompletionException:
org.apache.pulsar.client.api.PulsarClientException:
java.util.concurrent.CompletionException:
org.apache.pulsar.shade.io.netty.channel.AbstractChannel$AnnotatedConnectException:
Connection refused: no further information:
pulsar://broker.example.com:6650/"},{"attempt":7,"error":"java.util.concurrent.CompletionException:
org.apache.pulsar.client.api.PulsarClientException:
java.util.concurrent.CompletionException:
org.apache.pulsar.shade.io.netty.channel.Abstract
Channel$AnnotatedConnectException: Connection refused: no further information:
pulsar://broker.example.com:6650/"},{"attempt":8,"error":"java.util.concurrent.CompletionException:
org.apache.pulsar.client.api.PulsarClientException:
java.util.concurrent.CompletionException:
org.apache.pulsar.shade.io.netty.channel.AbstractChannel$AnnotatedConnectException:
Connection refused: no further information:
pulsar://broker.example.com:6650/"},{"attempt":9,"error":"java.util.concurrent.CompletionException:
org.apache.pulsar.client.api.PulsarClientException:
java.util.concurrent.CompletionException:
org.apache.pulsar.shade.io.netty.channel.AbstractChannel$AnnotatedConnectException:
Connection refused: no further information:
pulsar://broker.example.com:6650/"}]}].-{ActivityName=PulsarProducer,
ProcessName=pulsarsrtest.Process, ModuleName=PulsarSRtest}`
GitHub link:
https://github.com/apache/pulsar/discussions/20344#discussioncomment-5947176
----
This is an automatically sent email for [email protected].
To unsubscribe, please send an email to: [email protected]
