Browse Source

Use response with the same version as request in MockDeleteTopicsResponse

Vitaly Agapov 6 years ago
parent
commit
00f3bf9126
1 changed files with 1 additions and 0 deletions
  1. 1 0
      mockresponses.go

+ 1 - 0
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
 }