You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@pulsar.apache.org by "rgaur12 (via GitHub)" <gi...@apache.org> on 2023/05/19 10:41:52 UTC

[GitHub] [pulsar] rgaur12 added a comment to the discussion: Connection timeout working is not same as described in the clientBuilder[Bug]

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.CompletionException: org.apache.pulsar.shade.io.netty.channel.AbstractChann
 el$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: C
 onnection 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.AbstractChannel$AnnotatedConnectException: Connection refused: no further i
 nformation: 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-5947156

----
This is an automatically sent email for commits@pulsar.apache.org.
To unsubscribe, please send an email to: commits-unsubscribe@pulsar.apache.org