wolfstudy edited a comment on pull request #366:
URL: https://github.com/apache/pulsar-client-go/pull/366#issuecomment-695945617
Hi @fracasula , I used the test case you provided and tried to run more than
10 times locally. I didn't reproduce. The locality can work normally.
The only change is that I encountered a `context deadline exceeded` during
the first execution, after which i adjusted the time of the context form 5
minutes to 10 minutes.
```
// New context
ctx, cancel = context.WithTimeout(context.Background(), 10*time.Minute)
t.Cleanup(cancel)
```
And the output as follows:
```
consumer_partition_integration_test.go:97: Got message 99991
consumer_partition_integration_test.go:97: Got message 99992
consumer_partition_integration_test.go:97: Got message 99993
consumer_partition_integration_test.go:97: Got message 99994
consumer_partition_integration_test.go:97: Got message 99995
consumer_partition_integration_test.go:97: Got message 99996
consumer_partition_integration_test.go:97: Got message 99997
consumer_partition_integration_test.go:97: Got message 99998
consumer_partition_integration_test.go:97: Got message 99999
consumer_partition_integration_test.go:97: Got message 100000
consumer_partition_integration_test.go:132: Test complete!
07:16:39.592 [Thread-1] INFO
org.apache.pulsar.functions.worker.FunctionMetaDataTopicTailer - Stopping
function metadata tailer
07:16:39.593 [pulsar-io-51-10] INFO
org.apache.pulsar.broker.service.ServerCnx - [/127.0.0.1:33174] Closing
consumer: 1
07:16:39.593 [pulsar-io-51-10] INFO
org.apache.pulsar.broker.service.AbstractDispatcherSingleActiveConsumer -
Removing consumer
Consumer{subscription=PersistentSubscription{topic=persistent://public/functions/metadata,
name=reader-758e557af5}, consumerId=1,
consumerName=c-standalone-fw-localhost-8080-function-metadata-manager,
address=/127.0.0.1:33174}
07:16:39.594 [pulsar-io-51-10] INFO
org.apache.pulsar.broker.service.persistent.PersistentSubscription -
[persistent://public/functions/metadata][reader-758e557af5] Successfully closed
subscription [NonDurableCursorImpl{ledger=public/functions/persistent/metadata,
ackPos=9:-1, readPos=9:0}]
```
---
```
go version
```
Output:
```
go version go1.14.6 darwin/amd64
```
----------------------------------------------------------------
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.
For queries about this service, please contact Infrastructure at:
[email protected]
