Function TestOffsetFetchResponseMultipleGroupsV8

offset_fetch_response_test.go:184–204

(t *testing.T)

}

func TestOffsetFetchResponseMultipleGroupsV8(t *testing.T) {
	response := OffsetFetchResponse{
		Version:        8,
		ThrottleTimeMs: 9,
		Blocks:         map[string]map[int32]*OffsetFetchResponseBlock{},
		Groups: []OffsetFetchResponseGroup{
			{GroupId: "blah", Blocks: map[string]map[int32]*OffsetFetchResponseBlock{}, Err: ErrNoError},
			{GroupId: "qux", Blocks: map[string]map[int32]*OffsetFetchResponseBlock{}, Err: ErrInvalidRequest},
		},
	}
	testResponse(t, "two groups v8", &response, offsetFetchResponseTwoGroupsV8)

	decoded := new(OffsetFetchResponse)
	require.NoError(t, versionedDecode(offsetFetchResponseTwoGroupsV8, decoded, 8, nil))
	require.Len(t, decoded.Groups, 2)
	assert.Equal(t, "blah", decoded.Groups[0].GroupId)
	assert.Equal(t, ErrNoError, decoded.Groups[0].Err)
	assert.Equal(t, "qux", decoded.Groups[1].GroupId)
	assert.Equal(t, ErrInvalidRequest, decoded.Groups[1].Err)
	assert.Equal(t, ErrNoError, decoded.GroupError())
}