diff --git a/mockresponses.go b/mockresponses.go index 79fdaff1a..39196f9f5 100644 --- a/mockresponses.go +++ b/mockresponses.go @@ -667,6 +667,7 @@ func (mr *MockDeleteTopicsResponse) For(reqBody versionedDecoder) encoder { for _, topic := range req.Topics { res.TopicErrorCodes[topic] = ErrNoError } + res.Version = int16(req.Version) return res }