Function TestOffsetFetchRequest

offset_fetch_request_test.go:149–206

(t *testing.T)

}

func TestOffsetFetchRequest(t *testing.T) {
	for version := 0; version <= 5; version++ {
		request := new(OffsetFetchRequest)
		request.Version = int16(version)
		request.ConsumerGroup = "blah"
		request.AddPartition("topicTheFirst", 0x4F4F4F4F)
		testRequest(t, fmt.Sprintf("one partition %d", version), request, offsetFetchRequestOnePartition)
	}

	{ // v6
		version := 6
		request := new(OffsetFetchRequest)
		request.Version = int16(version)
		request.ConsumerGroup = "blah"
		request.AddPartition("topicTheFirst", 0x4F4F4F4F)
		testRequest(t, fmt.Sprintf("one partition %d", version), request, offsetFetchRequestOnePartitionV6)
	}

	{ // v7
		version := 7
		request := new(OffsetFetchRequest)
		request.Version = int16(version)
		request.ConsumerGroup = "blah"
		request.AddPartition("topicTheFirst", 0x4F4F4F4F)
		testRequest(t, fmt.Sprintf("one partition %d", version), request, offsetFetchRequestOnePartitionV7)
	}

	{ // v8
		request := &OffsetFetchRequest{
			Version: 8,
			Groups: []OffsetFetchRequestGroup{
				{GroupId: "blah", Partitions: map[string][]int32{"topicTheFirst": {0x4F4F4F4F}}},
			},
		}
		testRequest(t, "one partition 8", request, offsetFetchRequestOnePartitionV8)
	}

	{ // v8, two groups
		request := &OffsetFetchRequest{
			Version: 8,
			Groups: []OffsetFetchRequestGroup{
				{GroupId: "blah", Partitions: map[string][]int32{}},
				{GroupId: "qux", Partitions: map[string][]int32{}},
			},
		}
		testRequest(t, "two groups v8", request, offsetFetchRequestTwoGroupsV8)
	}

	{ // downgraded single-group v8 request
		request := &OffsetFetchRequest{
			Version: 7,
			Groups: []OffsetFetchRequestGroup{
				{GroupId: "blah", Partitions: map[string][]int32{"topicTheFirst": {0x4F4F4F4F}}},
			},
		}
		testRequestEncode(t, "downgraded single group fallback", request, offsetFetchRequestOnePartitionV7)
	}
}