diff --git a/Cargo.lock b/Cargo.lock index 3997fc6cb8..701fe8846e 100644 --- a/Cargo.lock +++ b/Cargo.lock @@ -2316,7 +2316,7 @@ dependencies = [ [[package]] name = "fluvio-socket" -version = "0.11.5" +version = "0.11.6" dependencies = [ "async-channel", "async-lock", diff --git a/crates/fluvio-socket/Cargo.toml b/crates/fluvio-socket/Cargo.toml index bd58555f30..8bdb6ded4b 100644 --- a/crates/fluvio-socket/Cargo.toml +++ b/crates/fluvio-socket/Cargo.toml @@ -1,6 +1,6 @@ [package] name = "fluvio-socket" -version = "0.11.5" +version = "0.11.6" edition = "2021" authors = ["Fluvio Contributors "] description = "Provide TCP socket wrapper for fluvio protocol" diff --git a/crates/fluvio-socket/src/multiplexing.rs b/crates/fluvio-socket/src/multiplexing.rs index 9a0ce602f0..40243fd4c6 100644 --- a/crates/fluvio-socket/src/multiplexing.rs +++ b/crates/fluvio-socket/src/multiplexing.rs @@ -170,7 +170,7 @@ impl MultiplexerSocket { Err(IoError::new( ErrorKind::TimedOut, - format!("Timed out waiting for response. API_KEY={}, CorrelationId={}", R::API_KEY, correlation_id), + format!("Timed out: {} secs waiting for response. API_KEY={}, CorrelationId={}", *MAX_WAIT_TIME,R::API_KEY, correlation_id), ).into()) },