(topic string, partition int32, offset int64, msg Encoder)
| 309 | } |
| 310 | |
| 311 | func (mfr *MockFetchResponse) SetMessage(topic string, partition int32, offset int64, msg Encoder) *MockFetchResponse { |
| 312 | return mfr.SetMessageWithKey(topic, partition, offset, nil, msg) |
| 313 | } |
| 314 | |
| 315 | func (mfr *MockFetchResponse) SetMessageWithKey(topic string, partition int32, offset int64, key, msg Encoder) *MockFetchResponse { |
| 316 | mfr.messagesLock.Lock() |