java deflate compress and decompress

DeflateUtil.java

public class DeflateUtil {
	public static byte[] compressBytes(final byte[] input) {
		final ByteArrayOutputStream bos = new ByteArrayOutputStream();
		final byte[] buf = new byte[1024];
		final Deflater compresser = new Deflater(Deflater.BEST_COMPRESSION);
		compresser.setInput(input);
		compresser.finish();
		while (!compresser.finished()) {
			final int compressedDataLength = compresser.deflate(buf);
			bos.write(buf, 0, compressedDataLength);
		}
		compresser.end();
		return bos.toByteArray();
	}

	public static byte[] decompressBytes(final byte[] input) throws DataFormatException {
		final ByteArrayOutputStream bos = new ByteArrayOutputStream();
		final byte[] buf = new byte[1024];
		final Inflater decompresser = new Inflater();
		decompresser.setInput(input, 0, input.length);
		while (!decompresser.finished()) {
			final int resultLength = decompresser.inflate(buf);
			bos.write(buf, 0, resultLength);
		}
		decompresser.end();
		return bos.toByteArray();
	}
}