MCPcopy
hub / github.com/IBM/sarama / SetMessage

Method SetMessage

mockresponses.go:311–313  ·  view source on GitHub ↗
(topic string, partition int32, offset int64, msg Encoder)

Source from the content-addressed store, hash-verified

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

Calls 1

SetMessageWithKeyMethod · 0.95