diff --git a/src/rpc_client/src/stream_client.rs b/src/rpc_client/src/stream_client.rs index 531a8669fdee..09a4c607043e 100644 --- a/src/rpc_client/src/stream_client.rs +++ b/src/rpc_client/src/stream_client.rs @@ -52,7 +52,9 @@ impl StreamClient { .await? .tracing_injected(); - Ok(Self(StreamServiceClient::new(channel))) + Ok(Self( + StreamServiceClient::new(channel).max_decoding_message_size(usize::MAX), + )) } }