fix: correct unsupported version check (#2528)

Signed-off-by: Mark Hindess <mark.hindess@gmail.com>
IBM · Jul 28, 2023 · 34bc8f9 · 34bc8f9
1 parent c28ecc0
commit 34bc8f9
Showing 1 changed file with 1 addition and 1 deletion.
diff --git a/metadata_request.go b/metadata_request.go
@@ -24,7 +24,7 @@ func NewMetadataRequest(version KafkaVersion, topics []string) *MetadataRequest
 }
 
 func (r *MetadataRequest) encode(pe packetEncoder) (err error) {
-	if r.Version < 0 || r.Version > 12 {
+	if r.Version < 0 || r.Version > 7 {
 		return PacketEncodingError{"invalid or unsupported MetadataRequest version field"}
 	}
 	if r.Version == 0 || len(r.Topics) > 0 {