From 368f526b9f71f6113b41ba87a993bf0d1bfab432 Mon Sep 17 00:00:00 2001 From: chrislu Date: Sat, 13 Sep 2025 18:36:39 -0700 Subject: [PATCH] fix Incorrect flexible version mapping --- weed/mq/kafka/protocol/flexible_versions.go | 2 +- 1 file changed, 1 insertion(+), 1 deletion(-) diff --git a/weed/mq/kafka/protocol/flexible_versions.go b/weed/mq/kafka/protocol/flexible_versions.go index b0825e827..7428d9d93 100644 --- a/weed/mq/kafka/protocol/flexible_versions.go +++ b/weed/mq/kafka/protocol/flexible_versions.go @@ -220,7 +220,7 @@ func IsFlexibleVersion(apiKey, apiVersion uint16) bool { case 13: // LeaveGroup return apiVersion >= 4 case 19: // CreateTopics - return apiVersion >= 2 + return apiVersion >= 5 case 20: // DeleteTopics return apiVersion >= 4 default: