Function BenchmarkMetadataResponse

protocol/metadata/metadata_test.go:155–199

(b *testing.B)

}

func BenchmarkMetadataResponse(b *testing.B) {
	prototest.BenchmarkResponse(b, v8, &metadata.Response{
		ThrottleTimeMs:              123,
		ClusterID:                   "test",
		ControllerID:                1,
		ClusterAuthorizedOperations: 0x01,
		Brokers: []metadata.ResponseBroker{
			{
				NodeID: 0,
				Host:   "127.0.0.1",
				Port:   9092,
				Rack:   "rack-1",
			},
			{
				NodeID: 1,
				Host:   "127.0.0.1",
				Port:   9093,
				Rack:   "rack-2",
			},
		},
		Topics: []metadata.ResponseTopic{
			{
				Name: "topic-1",
				Partitions: []metadata.ResponsePartition{
					{
						PartitionIndex:  0,
						LeaderID:        1,
						LeaderEpoch:     1234567890,
						ReplicaNodes:    []int32{0},
						IsrNodes:        []int32{0},
						OfflineReplicas: []int32{1},
					},
					{
						ErrorCode:       1,
						ReplicaNodes:    []int32{},
						IsrNodes:        []int32{},
						OfflineReplicas: []int32{},
					},
				},
				TopicAuthorizedOperations: 0x01,
			},
		},
	})

}