diff --git a/metadata_request.go b/metadata_request.go index a1b6ac09c..e0462b720 100644 --- 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 {