Class CrcTest

clients/src/test/java/org/apache/kafka/common/utils/CrcTest.java:24–59

import java.nio.ByteBuffer;

public class CrcTest {

    @Test
    public void testUpdate() {
        final byte bytes[] = "Any String you want".getBytes();
        final int len = bytes.length;

        Crc32 crc1 = new Crc32();
        Crc32 crc2 = new Crc32();
        Crc32 crc3 = new Crc32();

        crc1.update(bytes, 0, len);
        for(int i = 0; i < len; i++)
            crc2.update(bytes[i]);
        crc3.update(bytes, 0, len/2);
        crc3.update(bytes, len/2, len-len/2);

        assertEquals("Crc values should be the same", crc1.getValue(), crc2.getValue());
        assertEquals("Crc values should be the same", crc1.getValue(), crc3.getValue());
    }

    @Test
    public void testUpdateInt() {
        final int value = 1000;
        final ByteBuffer buffer = ByteBuffer.allocate(4);
        buffer.putInt(value);

        Crc32 crc1 = new Crc32();
        Crc32 crc2 = new Crc32();

        crc1.updateInt(value);
        crc2.update(buffer.array(), buffer.arrayOffset(), 4);

        assertEquals("Crc values should be the same", crc1.getValue(), crc2.getValue());
    }
}