fix: correct unsupported version check

hindessm · hindessm · commit 916c6557a315 · 2023-07-28T10:04:00.000+01:00
Signed-off-by: Mark Hindess &lt;mark.hindess@gmail.com&gt;
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 {

Original file line number	Diff line number	Diff line change
`@@ -24,7 +24,7 @@ func NewMetadataRequest(version KafkaVersion, topics []string) *MetadataRequest`
`24`	`24`	`}`
`25`	`25`
`26`	`26`	`func (r *MetadataRequest) encode(pe packetEncoder) (err error) {`
`27`		`- if r.Version < 0 \|\| r.Version > 12 {`
	`27`	`+ if r.Version < 0 \|\| r.Version > 7 {`
`28`	`28`	`return PacketEncodingError{"invalid or unsupported MetadataRequest version field"}`
`29`	`29`	`}`
`30`	`30`	`if r.Version == 0 \|\| len(r.Topics) > 0 {`