Skip to content

Commit 5ef3fd3

Browse files
authored
Fixed a problem that caused response errors when compression is enabled. (#1621)
1 parent a8b308a commit 5ef3fd3

File tree

3 files changed

+9
-3
lines changed

3 files changed

+9
-3
lines changed

opentelemetry-otlp/src/exporter/tonic/logs.rs

+3-1
Original file line numberDiff line numberDiff line change
@@ -33,7 +33,9 @@ impl TonicLogsClient {
3333
) -> Self {
3434
let mut client = LogsServiceClient::new(channel);
3535
if let Some(compression) = compression {
36-
client = client.send_compressed(compression);
36+
client = client
37+
.send_compressed(compression)
38+
.accept_compressed(compression);
3739
}
3840

3941
TonicLogsClient {

opentelemetry-otlp/src/exporter/tonic/metrics.rs

+3-1
Original file line numberDiff line numberDiff line change
@@ -35,7 +35,9 @@ impl TonicMetricsClient {
3535
) -> Self {
3636
let mut client = MetricsServiceClient::new(channel);
3737
if let Some(compression) = compression {
38-
client = client.send_compressed(compression);
38+
client = client
39+
.send_compressed(compression)
40+
.accept_compressed(compression);
3941
}
4042

4143
TonicMetricsClient {

opentelemetry-otlp/src/exporter/tonic/trace.rs

+3-1
Original file line numberDiff line numberDiff line change
@@ -33,7 +33,9 @@ impl TonicTracesClient {
3333
) -> Self {
3434
let mut client = TraceServiceClient::new(channel);
3535
if let Some(compression) = compression {
36-
client = client.send_compressed(compression);
36+
client = client
37+
.send_compressed(compression)
38+
.accept_compressed(compression);
3739
}
3840

3941
TonicTracesClient {

0 commit comments

Comments
 (0)