Function TestOffsetFetchRequestAllPartitions

offset_fetch_request_test.go:258–283

(t *testing.T)

}

func TestOffsetFetchRequestAllPartitions(t *testing.T) {
	for version := 2; version <= 5; version++ {
		request := &OffsetFetchRequest{Version: int16(version), ConsumerGroup: "blah"}
		testRequest(t, fmt.Sprintf("all partitions %d", version), request, offsetFetchRequestAllPartitions)
	}

	{ // v8
		request := &OffsetFetchRequest{
			Version: 8,
			Groups: []OffsetFetchRequestGroup{
				{GroupId: "blah", Partitions: nil},
			},
		}
		testRequest(t, "all partitions 8", request, offsetFetchRequestAllPartitionsV8)
	}

	{ // decoded v8 null topics array
		request := new(OffsetFetchRequest)
		require.NoError(t, versionedDecode(offsetFetchRequestAllPartitionsV8, request, 8, nil))
		require.Len(t, request.Groups, 1)
		assert.Nil(t, request.Groups[0].Partitions)

		packet := testRequestEncode(t, "decoded all partitions 8", request, offsetFetchRequestAllPartitionsV8)
		testRequestDecode(t, "decoded all partitions 8", request, packet)
	}
}

func TestNewOffsetFetchRequestDowngrade(t *testing.T) {
	request := NewOffsetFetchRequest(V3_0_0_0, "blah", map[string][]int32{"topicTheFirst": {0x4F4F4F4F}})