diff --git a/fetch_request.go b/fetch_request.go index 836e6dec1..58130e0cd 100644 --- a/fetch_request.go +++ b/fetch_request.go @@ -228,6 +228,7 @@ func (r *FetchRequest) version() int16 { return r.Version } +// FIXME: get these correct func (r *FetchRequest) requiredVersion() KafkaVersion { switch r.Version { case 0: diff --git a/fetch_response.go b/fetch_response.go index 11e4543ba..36a020bc1 100644 --- a/fetch_response.go +++ b/fetch_response.go @@ -324,6 +324,7 @@ func (r *FetchResponse) version() int16 { return r.Version } +// FIXME: get these correct func (r *FetchResponse) requiredVersion() KafkaVersion { switch r.Version { case 0: