diff options
| author | alexbogo <alexbogo@ydb.tech> | 2022-08-19 13:10:09 +0300 |
|---|---|---|
| committer | alexbogo <alexbogo@ydb.tech> | 2022-08-19 13:10:09 +0300 |
| commit | 36af596cd430a979838e9e66aad25ea0b380838f (patch) | |
| tree | b4ba8f92415704ce7b7ac35bb14d04c8209d35cb | |
| parent | 03973a7bbef63b11054496d81516375c437f1202 (diff) | |
| download | ydb-36af596cd430a979838e9e66aad25ea0b380838f.tar.gz | |
[mirrorer] use aync discovery in persqueue client
init
| -rw-r--r-- | ydb/core/persqueue/actor_persqueue_client_iface.h | 1 |
1 files changed, 1 insertions, 0 deletions
diff --git a/ydb/core/persqueue/actor_persqueue_client_iface.h b/ydb/core/persqueue/actor_persqueue_client_iface.h index 2588e1ec3e..29478c4de0 100644 --- a/ydb/core/persqueue/actor_persqueue_client_iface.h +++ b/ydb/core/persqueue/actor_persqueue_client_iface.h @@ -81,6 +81,7 @@ public: ) const override { NYdb::NPersQueue::TPersQueueClientSettings clientSettings = NYdb::NPersQueue::TPersQueueClientSettings() .DiscoveryEndpoint(TStringBuilder() << config.GetEndpoint() << ":" << config.GetEndpointPort()) + .DiscoveryMode(NYdb::EDiscoveryMode::Async) .CredentialsProviderFactory(credentialsProviderFactory) .EnableSsl(config.GetUseSecureConnection()); if (config.HasDatabase()) { |