diff --git a/lib/cpp/src/thrift/transport/TBufferTransports.cpp b/lib/cpp/src/thrift/transport/TBufferTransports.cpp
index 2d67aff..a133422 100644
--- a/lib/cpp/src/thrift/transport/TBufferTransports.cpp
+++ b/lib/cpp/src/thrift/transport/TBufferTransports.cpp
@@ -308,6 +308,8 @@
     setReadBuffer(rBuf_.get(), rBufSize_);
   }
 
+  resetConsumedMessageSize();
+
   return bytes_read;
 }