diff --git a/functional_producer_test.go b/functional_producer_test.go
index 2ab775319..96272d0fb 100644
--- a/functional_producer_test.go
+++ b/functional_producer_test.go
@@ -1021,7 +1021,7 @@ func validateProducerMetrics(t *testing.T, client Client) {
 		// We record compression ratios of 1.00 (100 with a histogram) for every TestBatchSize record
 		if client.Config().Version.IsAtLeast(V0_11_0_0) {
 			// records will be grouped in batchSet rather than msgSet
-			metricValidators.registerForGlobalAndTopic("test_1", minCountHistogramValidator("compression-ratio", 4))
+			metricValidators.registerForGlobalAndTopic("test_1", minCountHistogramValidator("compression-ratio", 3))
 		} else {
 			metricValidators.registerForGlobalAndTopic("test_1", countHistogramValidator("compression-ratio", TestBatchSize))
 		}