ericsyh commented on issue #698:
URL:
https://github.com/apache/pulsar-client-go/issues/698#issuecomment-1019398131
i cannot reproduce this issue, from my log the consumer gets the message
after broker recovers.
```
consumer:(*pulsar.partitionConsumer)(0xc0001b8b60),
receivedTime:time.Time{wall:0xc0731d80a6597d58, ext:48007551737,
loc:(*time.Location)(0x4bbbba0)}} -- content: 'hello-28'
Received message msgId:
pulsar.trackingMessageID{messageID:pulsar.messageID{ledgerID:26, entryID:29,
batchIdx:0, partitionIdx:0}, tracker:(*pulsar.ackTracker)(nil),
consumer:(*pulsar.partitionConsumer)(0xc0001b8b60),
receivedTime:time.Time{wall:0xc0731d8187437388, ext:51485933665,
loc:(*time.Location)(0x4bbbba0)}} -- content: 'hello-29'
INFO[0053] [Reconnecting to broker in 100.033744ms] consumerID=1
name=oxkrn subscription=issue-1 topic="persistent://public/default/issue-610"
WARN[0053] [Failed to lookup topic]
error=ServiceNotReady
message="org.apache.pulsar.client.api.PulsarClientException:
java.util.concurrent.CompletionException:
io.netty.channel.AbstractChannel$AnnotatedConnectException: finishConnect(..)
failed: Connection refused:
sn-pulsar-broker.sn.svc.cluster.local/10.244.0.33:6650"
serviceURL="pulsar://20.127.48.61:30950"
topic="persistent://public/default/issue-610"
WARN[0053] [Failed to lookup topic] consumerID=1
error=ServiceNotReady name=oxkrn subscription=issue-1
topic="persistent://public/default/issue-610"
INFO[0053] [Reconnecting to broker in 200.005976ms] consumerID=1
name=oxkrn subscription=issue-1 topic="persistent://public/default/issue-610"
WARN[0054] [Failed to lookup topic]
error=ServiceNotReady
message="org.apache.pulsar.client.api.PulsarClientException:
java.util.concurrent.CompletionException:
io.netty.channel.AbstractChannel$AnnotatedConnectException: finishConnect(..)
failed: Connection refused:
sn-pulsar-broker.sn.svc.cluster.local/10.244.0.33:6650"
serviceURL="pulsar://20.127.48.61:30950"
topic="persistent://public/default/issue-610"
WARN[0054] [Failed to lookup topic] consumerID=1
error=ServiceNotReady name=oxkrn subscription=issue-1
topic="persistent://public/default/issue-610"
INFO[0054] [Reconnecting to broker in 401.764131ms] consumerID=1
name=oxkrn subscription=issue-1 topic="persistent://public/default/issue-610"
WARN[0054] [Failed to lookup topic]
error=ServiceNotReady
message="org.apache.pulsar.client.api.PulsarClientException:
java.util.concurrent.CompletionException:
io.netty.channel.AbstractChannel$AnnotatedConnectException: finishConnect(..)
failed: Connection refused:
sn-pulsar-broker.sn.svc.cluster.local/10.244.0.33:6650"
serviceURL="pulsar://20.127.48.61:30950"
topic="persistent://public/default/issue-610"
WARN[0054] [Failed to lookup topic] consumerID=1
error=ServiceNotReady name=oxkrn subscription=issue-1
topic="persistent://public/default/issue-610"
INFO[0054] [Reconnecting to broker in 811.732192ms] consumerID=1
name=oxkrn subscription=issue-1 topic="persistent://public/default/issue-610"
WARN[0055] [Failed to lookup topic]
error=ServiceNotReady
message="org.apache.pulsar.client.api.PulsarClientException:
java.util.concurrent.CompletionException:
io.netty.channel.AbstractChannel$AnnotatedConnectException: finishConnect(..)
failed: Connection refused:
sn-pulsar-broker.sn.svc.cluster.local/10.244.0.33:6650"
serviceURL="pulsar://20.127.48.61:30950"
topic="persistent://public/default/issue-610"
WARN[0055] [Failed to lookup topic] consumerID=1
error=ServiceNotReady name=oxkrn subscription=issue-1
topic="persistent://public/default/issue-610"
INFO[0055] [Reconnecting to broker in 1.617550968s] consumerID=1
name=oxkrn subscription=issue-1 topic="persistent://public/default/issue-610"
WARN[0067] [Failed to lookup topic]
error=ServiceNotReady
message="org.apache.pulsar.client.api.PulsarClientException:
java.util.concurrent.CompletionException:
io.netty.channel.ConnectTimeoutException: connection timed out:
sn-pulsar-broker.sn.svc.cluster.local/10.244.0.33:6650"
serviceURL="pulsar://20.127.48.61:30950"
topic="persistent://public/default/issue-610"
WARN[0067] [Failed to lookup topic] consumerID=1
error=ServiceNotReady name=oxkrn subscription=issue-1
topic="persistent://public/default/issue-610"
INFO[0067] [Reconnecting to broker in 3.527264261s] consumerID=1
name=oxkrn subscription=issue-1 topic="persistent://public/default/issue-610"
WARN[0081] [Failed to lookup topic]
error=ServiceNotReady
message="org.apache.pulsar.client.api.PulsarClientException:
java.util.concurrent.CompletionException:
io.netty.channel.ConnectTimeoutException: connection timed out:
sn-pulsar-broker.sn.svc.cluster.local/10.244.0.33:6650"
serviceURL="pulsar://20.127.48.61:30950"
topic="persistent://public/default/issue-610"
WARN[0081] [Failed to lookup topic] consumerID=1
error=ServiceNotReady name=oxkrn subscription=issue-1
topic="persistent://public/default/issue-610"
INFO[0081] [Reconnecting to broker in 7.62042755s] consumerID=1
name=oxkrn subscription=issue-1 topic="persistent://public/default/issue-610"
WARN[0099] [Failed to lookup topic]
error=ServiceNotReady
message="org.apache.pulsar.client.api.PulsarClientException:
java.util.concurrent.CompletionException:
io.netty.channel.ConnectTimeoutException: connection timed out:
sn-pulsar-broker.sn.svc.cluster.local/10.244.0.33:6650"
serviceURL="pulsar://20.127.48.61:30950"
topic="persistent://public/default/issue-610"
WARN[0099] [Failed to lookup topic] consumerID=1
error=ServiceNotReady name=oxkrn subscription=issue-1
topic="persistent://public/default/issue-610"
INFO[0099] [Reconnecting to broker in 14.384485779s] consumerID=1
name=oxkrn subscription=issue-1 topic="persistent://public/default/issue-610"
WARN[0124] [Failed to lookup topic]
error=ServiceNotReady
message="org.apache.pulsar.client.api.PulsarClientException:
java.util.concurrent.CompletionException:
io.netty.channel.ConnectTimeoutException: connection timed out:
sn-pulsar-broker.sn.svc.cluster.local/10.244.0.33:6650"
serviceURL="pulsar://20.127.48.61:30950"
topic="persistent://public/default/issue-610"
WARN[0124] [Failed to lookup topic] consumerID=1
error=ServiceNotReady name=oxkrn subscription=issue-1
topic="persistent://public/default/issue-610"
INFO[0124] [Reconnecting to broker in 27.50338365s] consumerID=1
name=oxkrn subscription=issue-1 topic="persistent://public/default/issue-610"
INFO[0152] [Connecting to broker]
remote_addr="pulsar://20.127.48.61:30950"
INFO[0152] [TCP connection established]
local_addr="10.6.16.20:55208" remote_addr="pulsar://20.127.48.61:30950"
INFO[0153] [Connection is ready]
local_addr="10.6.16.20:55208" remote_addr="pulsar://20.127.48.61:30950"
INFO[0153] [Connected consumer] consumerID=1
name=oxkrn subscription=issue-1 topic="persistent://public/default/issue-610"
INFO[0153] [Reconnected consumer to broker] consumerID=1
name=oxkrn subscription=issue-1 topic="persistent://public/default/issue-610"
Received message msgId:
pulsar.trackingMessageID{messageID:pulsar.messageID{ledgerID:26, entryID:30,
batchIdx:0, partitionIdx:0}, tracker:(*pulsar.ackTracker)(nil),
consumer:(*pulsar.partitionConsumer)(0xc0001b8b60),
receivedTime:time.Time{wall:0xc0731d9b4ac17aa0, ext:154542160943,
loc:(*time.Location)(0x4bbbba0)}} -- content: 'hello-30'
Received message msgId:
pulsar.trackingMessageID{messageID:pulsar.messageID{ledgerID:31, entryID:0,
batchIdx:0, partitionIdx:0}, tracker:(*pulsar.ackTracker)(nil),
consumer:(*pulsar.partitionConsumer)(0xc0001b8b60),
receivedTime:time.Time{wall:0xc0731da79fa93980, ext:203891761323,
loc:(*time.Location)(0x4bbbba0)}} -- content: 'hello-0'
Received message msgId:
pulsar.trackingMessageID{messageID:pulsar.messageID{ledgerID:31, entryID:1,
batchIdx:0, partitionIdx:0}, tracker:(*pulsar.ackTracker)(nil),
consumer:(*pulsar.partitionConsumer)(0xc0001b8b60),
receivedTime:time.Time{wall:0xc0731da7b811be98, ext:204301254830,
loc:(*time.Location)(0x4bbbba0)}} -- content: 'hello-1'
```
--
This is an automated message from the Apache Git Service.
To respond to the message, please log on to GitHub and use the
URL above to go to the specific comment.
To unsubscribe, e-mail: commits-unsubscr...@pulsar.apache.org
For queries about this service, please contact Infrastructure at:
us...@infra.apache.org
