Skip to content

Commit 70dc9da

Browse files
committed
Make freezer messages discardable
This makes freezer messages discardable to enable lower memory use in consumers.
1 parent bd9b0f9 commit 70dc9da

File tree

1 file changed

+7
-0
lines changed

1 file changed

+7
-0
lines changed

freezer/freezer.go

+7
Original file line numberDiff line numberDiff line change
@@ -197,5 +197,12 @@ type consumerMessage struct {
197197
}
198198

199199
func (cm *consumerMessage) Data() []byte {
200+
if cm.data == nil {
201+
panic("attempt to use payload after discarding.")
202+
}
200203
return cm.data
201204
}
205+
206+
func (cm *consumerMessage) DiscardPayload() {
207+
cm.data = nil
208+
}

0 commit comments

Comments
 (0)