diff --git a/metadata_response.go b/metadata_response.go index 3be840e08..52ad9820e 100644 --- a/metadata_response.go +++ b/metadata_response.go @@ -448,7 +448,7 @@ func (r *MetadataResponse) headerVersion() int16 { } func (r *MetadataResponse) isValidVersion() bool { - return r.Version >= 0 && r.Version <= 7 + return r.Version >= 0 && r.Version <= 10 } func (r *MetadataResponse) requiredVersion() KafkaVersion {