(t *testing.T, msg *ConsumerMessage, expectedValue Encoder)
| 2064 | } |
| 2065 | |
| 2066 | func assertMessageValue(t *testing.T, msg *ConsumerMessage, expectedValue Encoder) { |
| 2067 | t.Helper() |
| 2068 | |
| 2069 | wantValue, _ := expectedValue.Encode() |
| 2070 | if !bytes.Equal(msg.Value, wantValue) { |
| 2071 | t.Fatalf("Incorrect value for message. expected=%s, actual=%s", expectedValue, msg.Key) |
| 2072 | } |
| 2073 | } |
| 2074 | |
| 2075 | func assertMessageOffset(t *testing.T, msg *ConsumerMessage, expectedOffset int64) { |
| 2076 | t.Helper() |
no test coverage detected