public int getNumInvalidMessages() {
    return numInvalidMessages;
  }
Return the number of invalid messages in current replication stream
@return numInvalidMessages
ambry-messageformat/src/main/java/com/github/ambry/messageformat/MessageSievingInputStream.java