func (s *OffsetStash) MarkPartitionOffset(topic string, partition int32, offset int64, metadata string) {
	s.mu.Lock()
	defer s.mu.Unlock()

	key := topicPartition{Topic: topic, Partition: partition}
	if info := s.offsets[key]; offset >= info.Offset {
		info.Offset = offset
		info.Metadata = metadata
		s.offsets[key] = info
	}
}
func (s *OffsetStash) MarkPartitionOffset(topic string, partition int32, offset int64, metadata string) {
	s.mu.Lock()
	defer s.mu.Unlock()

	key := topicPartition{Topic: topic, Partition: partition}
	if info := s.offsets[key]; offset >= info.Offset {
		info.Offset = offset
		info.Metadata = metadata
		s.offsets[key] = info
	}
}
func ( s * OffsetStash ) MarkPartitionOffset ( topic string , partition int32 , offset int64 , metadata string ) { s . mu . Lock ( ) defer s . mu . Unlock ( ) key := topicPartition { Topic : topic , Partition : partition } if info := s . offsets [ key ] ; offset >= info . Offset { info . Offset = offset info . Metadata = metadata s . offsets [ key ] = info } }
// MarkPartitionOffset stashes the offset for the provided topic/partition combination
MarkPartitionOffset stashes the offset for the provided topic / partition combination