From 6cac81045b609c619a948b0969db6c7f3b3fe06d Mon Sep 17 00:00:00 2001 From: Travis Bischel Date: Wed, 19 Oct 2022 20:56:39 -0600 Subject: [PATCH] kversions: bump Stable from 3.0 to 3.3 --- pkg/kversion/kversion.go | 11 +++++++---- 1 file changed, 7 insertions(+), 4 deletions(-) diff --git a/pkg/kversion/kversion.go b/pkg/kversion/kversion.go index cb42af12..0a747da8 100644 --- a/pkg/kversion/kversion.go +++ b/pkg/kversion/kversion.go @@ -322,7 +322,7 @@ func (vs *Versions) String() string { // Stable is a shortcut for the latest _released_ Kafka versions. // // This is the default version used in kgo to avoid breaking tip changes. -func Stable() *Versions { return zkBrokerOf(max300) } +func Stable() *Versions { return zkBrokerOf(maxStable) } // Tip is the latest defined Kafka key versions; this may be slightly out of date. func Tip() *Versions { return zkBrokerOf(maxTip) } @@ -934,6 +934,9 @@ var max330 = nextMax(max320, func(v listenerKeys) listenerKeys { return v }) -var maxTip = nextMax(max330, func(v listenerKeys) listenerKeys { - return v -}) +var ( + maxStable = max330 + maxTip = nextMax(maxStable, func(v listenerKeys) listenerKeys { + return v + }) +)