Skip to content

Commit 59295be

Browse files
authored
Merge pull request #166 from influxdata/dom/fix-pre-warm-connections
fix: pre-warm cache broker connections
2 parents cb9195a + 64211b5 commit 59295be

File tree

1 file changed

+1
-3
lines changed

1 file changed

+1
-3
lines changed

src/client/partition.rs

Lines changed: 1 addition & 3 deletions
Original file line numberDiff line numberDiff line change
@@ -117,9 +117,7 @@ impl PartitionClient {
117117
&*brokers,
118118
"leader_detection",
119119
|| async move {
120-
scope
121-
.get_leader(MetadataLookupMode::CachedArbitrary)
122-
.await?;
120+
scope.get().await?;
123121
Ok(())
124122
},
125123
)

0 commit comments

Comments
 (0)