Function TestOffsetCommitResponse

protocol/offsetcommit/offsetcommit_test.go:183–220

(t *testing.T)

}

func TestOffsetCommitResponse(t *testing.T) {
	// Fields are the same through version 2.
	for _, version := range []int16{0, 1, 2} {
		prototest.TestResponse(t, version, &offsetcommit.Response{
			Topics: []offsetcommit.ResponseTopic{
				{
					Name: "topic-1",
					Partitions: []offsetcommit.ResponsePartition{
						{
							PartitionIndex: 4,
							ErrorCode:      34,
						},
					},
				},
			},
		})
	}

	// Version 3 added:
	// ThrottleTimeMs
	// Field are the same through version 7.
	for _, version := range []int16{3, 4, 5, 6, 7} {
		prototest.TestResponse(t, version, &offsetcommit.Response{
			ThrottleTimeMs: 10000,
			Topics: []offsetcommit.ResponseTopic{
				{
					Name: "topic-2",
					Partitions: []offsetcommit.ResponsePartition{
						{
							PartitionIndex: 2,
							ErrorCode:      3,
						},
					},
				},
			},
		})
	}
}