diff --git a/pkg/kversion/kversion.go b/pkg/kversion/kversion.go index facad4e2..42efecd2 100644 --- a/pkg/kversion/kversion.go +++ b/pkg/kversion/kversion.go @@ -445,6 +445,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)} }