From 2a3b6bd0d045f52b9dc802176a8d6448508edeeb Mon Sep 17 00:00:00 2001
From: Travis Bischel <travis.bischel+github@gmail.com>
Date: Thu, 19 Oct 2023 17:05:55 -0600
Subject: [PATCH] pkg/kversion: detect 3.6

This does not yet add V3_6_0 since that will require a minor.
---
 pkg/kversion/kversion.go | 14 +++++++++++++-
 1 file changed, 13 insertions(+), 1 deletion(-)

diff --git a/pkg/kversion/kversion.go b/pkg/kversion/kversion.go
index facad4e2..f6d27c97 100644
--- a/pkg/kversion/kversion.go
+++ b/pkg/kversion/kversion.go
@@ -304,6 +304,7 @@ func (vs *Versions) versionGuess(opts ...VersionGuessOpt) guess {
 		{max330, "v3.3"},
 		{max340, "v3.4"},
 		{max350, "v3.5"},
+		{max360, "v3.6"},
 	} {
 		for k, v := range comparison.cmp.filter(cfg.listener) {
 			if v == -1 {
@@ -445,6 +446,10 @@ func V3_3_0() *Versions  { return zkBrokerOf(max330) }
 func V3_4_0() *Versions  { return zkBrokerOf(max340) }
 func V3_5_0() *Versions  { return zkBrokerOf(max350) }
 
+/* TODO wait for franz-go v1.16
+func V3_6_0() *Versions  { return zkBrokerOf(max360) }
+*/
+
 func zkBrokerOf(lks listenerKeys) *Versions {
 	return &Versions{lks.filter(zkBroker)}
 }
@@ -1051,8 +1056,15 @@ var max350 = nextMax(max340, func(v listenerKeys) listenerKeys {
 	return v
 })
 
+var max360 = nextMax(max350, func(v listenerKeys) listenerKeys {
+	// KAFKA-14402 29a1a16668d76a1cc04ec9e39ea13026f2dce1de KIP-890
+	// Later commit swapped to stable
+	v[24].inc() // 4 add partitions to txn
+	return v
+})
+
 var (
-	maxStable = max350
+	maxStable = max360
 	maxTip    = nextMax(maxStable, func(v listenerKeys) listenerKeys {
 		return v
 	})