Skip to content

Commit

Permalink
dekaf: Test whether re-using gazette clients fixes timeouts
Browse files Browse the repository at this point in the history
  • Loading branch information
jshearer committed Oct 7, 2024
1 parent 990b986 commit 8c4538b
Showing 1 changed file with 15 additions and 0 deletions.
15 changes: 15 additions & 0 deletions crates/flow-client/src/client.rs
Original file line number Diff line number Diff line change
Expand Up @@ -68,9 +68,24 @@ impl Client {
user_access_token: Option<String>,
user_refresh_token: Option<RefreshToken>,
) -> Self {
// Test whether a fresh set of Gazette clients solves the timeout issue
let router = gazette::Router::new("local");

let journal_client = gazette::journal::Client::new(
String::new(),
gazette::Metadata::default(),
router.clone(),
);
let shard_client = gazette::shard::Client::new(
String::new(),
gazette::Metadata::default(),
router.clone(),
);
Self {
user_access_token: user_access_token.or(self.user_access_token),
user_refresh_token: user_refresh_token.or(self.user_refresh_token),
journal_client,
shard_client,
..self
}
}
Expand Down

0 comments on commit 8c4538b

Please sign in to comment.