func (c *Consumer) ResetPartitionOffset(topic string, partition int32, offset int64, metadata string) {
	sub := c.subs.Fetch(topic, partition)
	if sub != nil {
		sub.ResetOffset(offset, metadata)
	}
}
func (c *Consumer) ResetPartitionOffset(topic string, partition int32, offset int64, metadata string) {
	sub := c.subs.Fetch(topic, partition)
	if sub != nil {
		sub.ResetOffset(offset, metadata)
	}
}
func ( c * Consumer ) ResetPartitionOffset ( topic string , partition int32 , offset int64 , metadata string ) { sub := c . subs . Fetch ( topic , partition ) if sub != nil { sub . ResetOffset ( offset , metadata ) } }
// ResetPartitionOffset marks an offset of the provided topic/partition as processed.
// See ResetOffset for additional explanation.
ResetPartitionOffset marks an offset of the provided topic / partition as processed . See ResetOffset for additional explanation .