diff --git a/src/client/controller.rs b/src/client/controller.rs index 06600144..63298a6e 100644 --- a/src/client/controller.rs +++ b/src/client/controller.rs @@ -96,13 +96,16 @@ impl ControllerClient { }; match error { + // broken connection Error::Request(RequestError::Poisoned(_) | RequestError::IO(_)) | Error::Connection(_) => self.invalidate_cached_controller_broker().await, - Error::ServerError(ProtocolError::LeaderNotAvailable, _) => {} - Error::ServerError(ProtocolError::OffsetNotAvailable, _) => {} + + // our broker is actually not the controller Error::ServerError(ProtocolError::NotController, _) => { self.invalidate_cached_controller_broker().await; } + + // fatal _ => { error!( e=%error,