@@ -0,0 +1,1078 @@
+package com.linkedin.databus.core.util;%0A%0Aimport java.io.ByteArrayInputStream;%0Aimport java.io.ByteArrayOutputStream;%0Aimport java.io.IOException;%0Aimport java.nio.charset.Charset;%0Aimport java.util.zip.GZIPInputStream;%0Aimport java.util.zip.GZIPOutputStream;%0A%0Apublic class CompressUtil%0A%7B%0A  public static String compress(String str) throws IOException%0A  %7B%0A    ByteArrayOutputStream out = new ByteArrayOutputStream();%0A    GZIPOutputStream gzip = new GZIPOutputStream(out);%0A    gzip.write(str.getBytes(Charset.defaultCharset()));%0A    gzip.close();%0A    String gzipStr = out.toString(%22ISO-8859-1%22);%0A    return gzipStr;%0A  %7D%0A%0A  public static String uncompress(String str) throws IOException%0A  %7B%0A    ByteArrayOutputStream out = new ByteArrayOutputStream();%0A    ByteArrayInputStream in = new ByteArrayInputStream(str.getBytes(%22ISO-8859-1%22));%0A    GZIPInputStream gunzip = new GZIPInputStream(in);%0A    byte%5B%5D buffer = new byte%5B256%5D;%0A    int n;%0A    while ((n = gunzip.read(buffer)) %3E= 0)%0A    %7B%0A      out.write(buffer, 0, n);%0A    %7D%0A    return out.toString(Charset.defaultCharset().name());%0A  %7D%0A%7D%0A

add compress utils