Function BenchmarkProduceRequest

protocol/produce/produce_test.go:206–273

(b *testing.B)

}

func BenchmarkProduceRequest(b *testing.B) {
	t0 := time.Now().Truncate(time.Millisecond)
	t1 := t0.Add(1 * time.Millisecond)
	t2 := t0.Add(2 * time.Millisecond)

	prototest.BenchmarkRequest(b, v3, &produce.Request{
		TransactionalID: "1234",
		Acks:            1,
		Timeout:         500,
		Topics: []produce.RequestTopic{
			{
				Topic: "topic-1",
				Partitions: []produce.RequestPartition{
					{
						Partition: 0,
						RecordSet: protocol.RecordSet{
							Version: 1,
							Records: protocol.NewRecordReader(
								protocol.Record{Offset: 0, Time: t0, Key: nil, Value: nil},
							),
						},
					},
					{
						Partition: 1,
						RecordSet: protocol.RecordSet{
							Version: 1,
							Records: protocol.NewRecordReader(
								protocol.Record{Offset: 0, Time: t0, Key: nil, Value: prototest.String("msg-0")},
								protocol.Record{Offset: 1, Time: t1, Key: nil, Value: prototest.String("msg-1")},
								protocol.Record{Offset: 2, Time: t2, Key: prototest.Bytes([]byte{1}), Value: prototest.String("msg-2")},
							),
						},
					},
				},
			},
		},
	})

	headers := []protocol.Header{
		{Key: "key-1", Value: []byte("value-1")},
		{Key: "key-2", Value: []byte("value-2")},
		{Key: "key-3", Value: []byte("value-3")},
	}

	prototest.BenchmarkRequest(b, v5, &produce.Request{
		TransactionalID: "1234",
		Acks:            1,
		Timeout:         500,
		Topics: []produce.RequestTopic{
			{
				Topic: "topic-1",
				Partitions: []produce.RequestPartition{
					{
						Partition: 1,
						RecordSet: protocol.RecordSet{
							Version: 2,
							Records: protocol.NewRecordReader(
								protocol.Record{Offset: 0, Time: t0, Key: nil, Value: prototest.String("msg-0"), Headers: headers},