code: func (conn *BytesConnectionFields) MarkOffset(msg client.ConsumerMessage, metadata string) {
  	if conn.multiplexer != nil && conn.multiplexer.Consumer != nil {
  		conn.multiplexer.Consumer.MarkOffset(&msg, metadata)
  	}
  }
docs: // MarkOffset marks the specified message as read