(t *testing.T)
| 109 | } |
| 110 | |
| 111 | func TestOffsetFetchResponseNullMetadata(t *testing.T) { |
| 112 | response := &OffsetFetchResponse{} |
| 113 | err := versionedDecode(offsetFetchResponseV0NullMetadata, response, 0, nil) |
| 114 | require.NoError(t, err) |
| 115 | |
| 116 | block := response.GetBlock("t", 0) |
| 117 | require.NotNil(t, block) |
| 118 | assert.Empty(t, block.Metadata) |
| 119 | assert.Equal(t, ErrRequestTimedOut, block.Err) |
| 120 | } |
| 121 | |
| 122 | func TestNormalOffsetFetchResponse(t *testing.T) { |
| 123 | // The response encoded form cannot be checked for it varies due to |
nothing calls this directly
no test coverage detected