You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@pulsar.apache.org by GitBox <gi...@apache.org> on 2021/08/31 06:06:32 UTC
[GitHub] [pulsar-client-go] yuvalgut opened a new issue #606: client keeps using an already closed producer
yuvalgut opened a new issue #606:
URL: https://github.com/apache/pulsar-client-go/issues/606
#### Expected behavior
when a producer is closed on the broker side, the client should recreate a producer.
#### Actual behavior
getting message send timeout: TimeoutError on the producer side
and on the broker side I see Producer had already been closed
#### Steps to reproduce
not sure
#### System configuration
**Pulsar version**: 2.7.0
golang pulsar client version: 0.6.0
--
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-unsubscribe@pulsar.apache.org
For queries about this service, please contact Infrastructure at:
users@infra.apache.org
[GitHub] [pulsar-client-go] liangyuanpeng commented on issue #606: client keeps using an already closed producer
Posted by GitBox <gi...@apache.org>.
liangyuanpeng commented on issue #606:
URL: https://github.com/apache/pulsar-client-go/issues/606#issuecomment-931868040
I testd producer can reconnect success.
1. pulsar start
2. producer start
3. pulsar shutdown
4. producer always print reonnect log
```shell
INFO[0060] [Got command! type:PARTITIONED_METADATA_RESPONSE partitionMetadataResponse:<partitions:0 request_id:5 response:Success > with payload size: 0 maxMsgSize: 5242880] local_addr="192.168.3.218:37702" remote_addr="pulsar://192.168.3.241:6650"
WARN[0064] [Failed to lookup topic] error="connection error" producerID=1 producer_name=standalone-0-4 topic="persistent://public/default/topic-1"
```
5. pulsar start
6. producer reconnect success and continue send message
pulsar 2.8.1
client-go 1d3a9cc80e63e67a9769d351539ac111c55e56ae
--
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-unsubscribe@pulsar.apache.org
For queries about this service, please contact Infrastructure at:
users@infra.apache.org