From 4e7e677c2cb986ceae8c674574a83b22ab1d1cfc Mon Sep 17 00:00:00 2001 From: Travis Bischel Date: Thu, 19 Oct 2023 17:05:55 -0600 Subject: [PATCH] pkg/kversion: detect 3.6 This does not yet add V3_6_0 since that will require a minor. --- pkg/kversion/kversion.go | 4 ++++ 1 file changed, 4 insertions(+) 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)} }