kversion: add V3_2_0
kcl version probed, integration tested
@@ -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
