diff --git a/functional_producer_test.go b/functional_producer_test.go
index ffaf81e491..8327068f34 100644
--- a/functional_producer_test.go
+++ b/functional_producer_test.go
@@ -23,11 +23,15 @@ const TestBatchSize = 1000
 
 func TestFuncProducing(t *testing.T) {
 	config := NewFunctionalTestConfig()
+	// FIXME: KAFKA_VERSION seems to break this test
+	config.Version = DefaultVersion
 	testProducingMessages(t, config)
 }
 
 func TestFuncProducingGzip(t *testing.T) {
 	config := NewFunctionalTestConfig()
+	// FIXME: KAFKA_VERSION seems to break this test
+	config.Version = DefaultVersion
 	config.Producer.Compression = CompressionGZIP
 	testProducingMessages(t, config)
 }
@@ -46,12 +50,16 @@ func TestFuncProducingZstd(t *testing.T) {
 
 func TestFuncProducingNoResponse(t *testing.T) {
 	config := NewFunctionalTestConfig()
+	// FIXME: KAFKA_VERSION seems to break this test
+	config.Version = DefaultVersion
 	config.Producer.RequiredAcks = NoResponse
 	testProducingMessages(t, config)
 }
 
 func TestFuncProducingFlushing(t *testing.T) {
 	config := NewFunctionalTestConfig()
+	// FIXME: KAFKA_VERSION seems to break this test
+	config.Version = DefaultVersion
 	config.Producer.Flush.Messages = TestBatchSize / 8
 	config.Producer.Flush.Frequency = 250 * time.Millisecond
 	testProducingMessages(t, config)