From 432b0b4d6ea9652e58d02e91f2361c1d90634a34 Mon Sep 17 00:00:00 2001 From: Dominic Evans Date: Thu, 25 Sep 2025 11:20:30 +0100 Subject: [PATCH] fix: add V4 as valid CreateTopicsResponse Missed in 1c971ae Signed-off-by: Dominic Evans --- create_topics_response.go | 4 +++- 1 file changed, 3 insertions(+), 1 deletion(-) diff --git a/create_topics_response.go b/create_topics_response.go index 1ef712d86..85d400840 100644 --- a/create_topics_response.go +++ b/create_topics_response.go @@ -83,11 +83,13 @@ func (c *CreateTopicsResponse) headerVersion() int16 { } func (c *CreateTopicsResponse) isValidVersion() bool { - return c.Version >= 0 && c.Version <= 3 + return c.Version >= 0 && c.Version <= 4 } func (c *CreateTopicsResponse) requiredVersion() KafkaVersion { switch c.Version { + case 4: + return V2_4_0_0 case 3: return V2_0_0_0 case 2: