kversion: add V3_2_0

kcl version probed, integration tested
twmb · May 23, 2022 · 5536ec1 · 5536ec1
1 parent 0f65bb1
commit 5536ec1
Showing 1 changed file with 7 additions and 1 deletion.
diff --git a/pkg/kversion/kversion.go b/pkg/kversion/kversion.go
@@ -221,6 +221,7 @@ func (vs *Versions) VersionGuess(opts ...VersionGuessOpt) string {
 		{max280, "v2.8"},
 		{max300, "v3.0"},
 		{max310, "v3.1"},
+		{max320, "v3.2"},
 	} {
 		for k, v := range comparison.cmp.filter(cfg.listener) {
 			if !skip[int16(k)] && v != -1 {
@@ -347,6 +348,7 @@ func V2_7_0() *Versions  { return zkBrokerOf(max270) }
 func V2_8_0() *Versions  { return zkBrokerOf(max280) }
 func V3_0_0() *Versions  { return zkBrokerOf(max300) }
 func V3_1_0() *Versions  { return zkBrokerOf(max310) }
+func V3_2_0() *Versions  { return zkBrokerOf(max320) }
 
 func zkBrokerOf(lks listenerKeys) *Versions {
 	return &Versions{lks.filter(zkBroker)}
@@ -888,7 +890,7 @@ var max310 = nextMax(max300, func(v listenerKeys) listenerKeys {
 	return v
 })
 
-var maxTip = nextMax(max310, func(v listenerKeys) listenerKeys {
+var max320 = nextMax(max310, func(v listenerKeys) listenerKeys {
 	// KAFKA-13495 69645f1fe5103adb00de6fa43152e7df989f3aea KIP-800
 	v[11].inc() // 8 join group
 
@@ -905,6 +907,10 @@ var maxTip = nextMax(max310, func(v listenerKeys) listenerKeys {
 	v[4].inc()  // 6 leader and isr
 	v[56].inc() // 1 alter isr => alter partition
 
+	return v
+})
+
+var maxTip = nextMax(max320, func(v listenerKeys) listenerKeys {
 	// KAFKA-13823 55ff5d360381af370fe5b3a215831beac49571a4 KIP-778
 	v[57].inc() // 1 update features