(t *testing.T)
| 24 | ) |
| 25 | |
| 26 | func TestConsumerMetadataResponseError(t *testing.T) { |
| 27 | response := &ConsumerMetadataResponse{Err: ErrOffsetsLoadInProgress} |
| 28 | testEncodable(t, "", response, consumerMetadataResponseError) |
| 29 | |
| 30 | decodedResp := &ConsumerMetadataResponse{} |
| 31 | if err := versionedDecode(consumerMetadataResponseError, decodedResp, 0, nil); err != nil { |
| 32 | t.Error("could not decode: ", err) |
| 33 | } |
| 34 | |
| 35 | if !errors.Is(decodedResp.Err, ErrOffsetsLoadInProgress) { |
| 36 | t.Errorf("got %s, want %s", decodedResp.Err, ErrOffsetsLoadInProgress) |
| 37 | } |
| 38 | } |
| 39 | |
| 40 | func TestConsumerMetadataResponseSuccess(t *testing.T) { |
| 41 | broker := NewBroker("foo:52445") |
nothing calls this directly
no test coverage detected