Function TestFetchRequest

protocol/fetch/fetch_test.go:17–35

(t *testing.T)

)

func TestFetchRequest(t *testing.T) {
	prototest.TestRequest(t, v0, &fetch.Request{
		ReplicaID:   -1,
		MaxWaitTime: 500,
		MinBytes:    1024,
		Topics: []fetch.RequestTopic{
			{
				Topic: "topic-1",
				Partitions: []fetch.RequestPartition{
					{
						Partition:         1,
						FetchOffset:       2,
						PartitionMaxBytes: 1024,
					},
				},
			},
		},
	})
}

func TestFetchResponse(t *testing.T) {
	t0 := time.Now().Truncate(time.Millisecond)