From 398d22e67c4ef40397c244ec631ef4a5cc1ecb58 Mon Sep 17 00:00:00 2001
From: Dominic Evans <dominic.evans@uk.ibm.com>
Date: Tue, 24 Dec 2024 21:54:41 +0000
Subject: [PATCH] fix(test): ensure versionRange is at least 2.1.0 for 4.0
 kafka

Signed-off-by: Dominic Evans <dominic.evans@uk.ibm.com>
---
 functional_consumer_test.go | 7 +++++++
 1 file changed, 7 insertions(+)

diff --git a/functional_consumer_test.go b/functional_consumer_test.go
index 53dd11879..a42c599d5 100644
--- a/functional_consumer_test.go
+++ b/functional_consumer_test.go
@@ -447,6 +447,13 @@ func versionRange(lower KafkaVersion) []KafkaVersion {
 		upper = MaxVersion
 	}
 
+	// KIP-896 dictates a minimum lower bound of 2.1 protocol for Kafka 4.0 onwards
+	if upper.IsAtLeast(V4_0_0_0) {
+		if !lower.IsAtLeast(V2_1_0_0) {
+			lower = V2_1_0_0
+		}
+	}
+
 	versions := make([]KafkaVersion, 0, len(fvtRangeVersions))
 	for _, v := range fvtRangeVersions {
 		if !v.IsAtLeast(lower) {