Skip to content

Commit

Permalink
kversions: bump Stable from 3.0 to 3.3
Browse files Browse the repository at this point in the history
  • Loading branch information
twmb committed Oct 20, 2022
1 parent 9387634 commit 6cac810
Showing 1 changed file with 7 additions and 4 deletions.
11 changes: 7 additions & 4 deletions pkg/kversion/kversion.go
Original file line number Diff line number Diff line change
Expand Up @@ -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) }
Expand Down Expand Up @@ -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
})
)

0 comments on commit 6cac810

Please sign in to comment.