crc32_test.go - golang-github-segmentio-kafka-go (HEAD)

Tree @HEAD (Download .tar.gz)

.circleci
debian
gzip
lz4
snappy
.gitignore
balancer.go
balancer_test.go
batch.go
batch_test.go
commit.go
commit_test.go
compression.go
compression_test.go
conn.go
conn_test.go
crc32.go
crc32_test.go
createtopics.go
createtopics_test.go
deletetopics.go
deletetopics_test.go
describegroups.go
describegroups_test.go
dialer.go
dialer_test.go
discard.go
discard_test.go
docker-compose.yml
error.go
error_test.go
example_writer_test.go
export_test.go
fetch.go
findcoordinator.go
findcoordinator_test.go
groupbalancer.go
groupbalancer_test.go
heartbeat.go
heartbeat_test.go
joingroup.go
joingroup_test.go
leavegroup.go
leavegroup_test.go
LICENSE
listgroups.go
listgroups_test.go
listoffset.go
message.go
metadata.go
offsetcommit.go
offsetcommit_test.go
offsetfetch.go
offsetfetch_test.go
produce.go
protocol.go
protocol_test.go
read.go
read_test.go
reader.go
reader_test.go
README.md
rungroup.go
rungroup_test.go
sizeof.go
stats.go
syncgroup.go
syncgroup_test.go
time.go
write.go
write_test.go
writer.go
writer_test.go

crc32_test.go @HEAD — raw · history · blame

package kafka

import (
	"bufio"
	"bytes"
	"hash/crc32"
	"testing"
)

func TestMessageCRC32(t *testing.T) {
	t.Parallel()

	m := message{
		MagicByte: 1,
		Timestamp: 42,
		Key:       nil,
		Value:     []byte("Hello World!"),
	}

	b := &bytes.Buffer{}
	w := bufio.NewWriter(b)
	write(w, m)
	w.Flush()

	h := crc32.NewIEEE()
	h.Write(b.Bytes()[4:])

	sum1 := h.Sum32()
	sum2 := uint32(m.crc32())

	if sum1 != sum2 {
		t.Error("bad CRC32:")
		t.Logf("expected: %d", sum1)
		t.Logf("found:    %d", sum2)
	}
}