(topic string, partition int32, offset int64, metadata string)
| 992 | } |
| 993 | |
| 994 | func (s *consumerGroupSession) ResetOffset(topic string, partition int32, offset int64, metadata string) { |
| 995 | if pom := s.offsets.findPOM(topic, partition); pom != nil { |
| 996 | pom.ResetOffset(offset, metadata) |
| 997 | } |
| 998 | } |
| 999 | |
| 1000 | func (s *consumerGroupSession) MarkMessage(msg *ConsumerMessage, metadata string) { |
| 1001 | s.MarkOffset(msg.Topic, msg.Partition, msg.Offset+1, metadata) |
nothing calls this directly
no test coverage detected