Function TestNewOffsetFetchRequestDowngrade

offset_fetch_request_test.go:285–292

(t *testing.T)

}

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

	assert.Equal(t, "blah", request.ConsumerGroup)
	assert.Equal(t, map[string][]int32{"topicTheFirst": {int32(0x4F4F4F4F)}}, request.partitions)
	testRequestEncode(t, "downgraded single group v8 request", request, offsetFetchRequestOnePartitionV7)
}