Function assertMessageKey

consumer_test.go:2055–2062

(t *testing.T, msg *ConsumerMessage, expectedKey Encoder)

}

func assertMessageKey(t *testing.T, msg *ConsumerMessage, expectedKey Encoder) {
	t.Helper()

	wantKey, _ := expectedKey.Encode()
	if !bytes.Equal(msg.Key, wantKey) {
		t.Fatalf("Incorrect key for message. expected=%s, actual=%s", expectedKey, msg.Key)
	}
}

func assertMessageValue(t *testing.T, msg *ConsumerMessage, expectedValue Encoder) {
	t.Helper()