code: func (conn *ProtoConnectionFields) MarkOffset(msg messaging.ProtoMessage, metadata string) {
  	if conn.multiplexer != nil && conn.multiplexer.Consumer != nil {
  		if msg == nil {
  			return
  		}
  		consumerMsg := &client.ConsumerMessage{
  			Topic:     msg.GetTopic(),
  			Partition: msg.GetPartition(),
  			Offset:    msg.GetOffset(),
  		}
  
  		conn.multiplexer.Consumer.MarkOffset(consumerMsg, metadata)
  	}
  }
docs: // MarkOffset marks the specified message as read