@Override
    public CompletionStage<Void> get(String id, OutputStream outputStream, Metadata metadata, boolean getDeletedBlob) {
      final String randBlob = "foobar";
      final byte[] byteArray = randBlob.getBytes(StandardCharsets.UTF_8);
      try {
        outputStream.write(byteArray);
      } catch (IOException e) {
        throw new RuntimeException(e);
      }
      return CompletableFuture.completedFuture(null);
    }
Test {@link BlobStoreManager} to be used to assert SnapshotIndex deserialization failure
exception message.
We write a dummy string's bytes to the OutputStream parameter of get method instead of a SnapshotIndex
blob. The OutputStream is used by SnapshotIndexSerde which will fail during deserialization.
samza-core/src/test/java/org/apache/samza/storage/blobstore/util/TestBlobStoreUtil.java