diff --git a/components/core/src/clp_s/SchemaReader.hpp b/components/core/src/clp_s/SchemaReader.hpp
index bbbb5303c..3680c6828 100644
--- a/components/core/src/clp_s/SchemaReader.hpp
+++ b/components/core/src/clp_s/SchemaReader.hpp
@@ -157,6 +157,11 @@ class SchemaReader {
      */
     void load(std::shared_ptr<char[]> stream_buffer, size_t offset, size_t uncompressed_size);
 
+    /**
+     * @return the number of messages in the schema
+     */
+    uint64_t get_num_messages() const { return m_num_messages; }
+
     /**
      * Gets next message
      * @param message