Method ResetOffset

consumer_group.go:870–870

ResetOffset resets to the provided offset, alongside a metadata string that represents the state of the partition consumer at that point in time. Reset acts as a counterpart to MarkOffset, the difference being that it allows to reset an offset to an earlier or smaller value, where MarkOffset only al

(topic string, partition int32, offset int64, metadata string)

	// reset an offset to an earlier or smaller value, where MarkOffset only
	// allows incrementing the offset. cf MarkOffset for more details.
	ResetOffset(topic string, partition int32, offset int64, metadata string)

	// MarkMessage marks a message as consumed.
	MarkMessage(msg *ConsumerMessage, metadata string)