Function TestFetchRequest

fetch_request_test.go:79–132

(t *testing.T)

)

func TestFetchRequest(t *testing.T) {
	t.Run("no blocks", func(t *testing.T) {
		request := new(FetchRequest)
		testRequest(t, "no blocks", request, fetchRequestNoBlocks)
	})

	t.Run("with properties", func(t *testing.T) {
		request := new(FetchRequest)
		request.MaxWaitTime = 0x20
		request.MinBytes = 0xEF
		testRequest(t, "with properties", request, fetchRequestWithProperties)
	})

	t.Run("one block", func(t *testing.T) {
		request := new(FetchRequest)
		request.MaxWaitTime = 0
		request.MinBytes = 0
		request.AddBlock("topic", 0x12, 0x34, 0x56, -1)
		testRequest(t, "one block", request, fetchRequestOneBlock)
	})

	t.Run("one block v4", func(t *testing.T) {
		request := new(FetchRequest)
		request.Version = 4
		request.MaxBytes = 0xFF
		request.Isolation = ReadCommitted
		request.AddBlock("topic", 0x12, 0x34, 0x56, -1)
		testRequest(t, "one block v4", request, fetchRequestOneBlockV4)
	})

	t.Run("one block v11 rackid and leader epoch", func(t *testing.T) {
		request := new(FetchRequest)
		request.Version = 11
		request.MaxBytes = 0xFF
		request.Isolation = ReadCommitted
		request.SessionID = 0xAA
		request.SessionEpoch = 0xEE
		request.AddBlock("topic", 0x12, 0x34, 0x56, 0x66)
		request.RackID = "rack01"
		testRequest(t, "one block v11 rackid", request, fetchRequestOneBlockV11)
	})

	t.Run("one block v12 flexible", func(t *testing.T) {
		request := new(FetchRequest)
		request.Version = 12
		request.MaxBytes = 0xFF
		request.Isolation = ReadCommitted
		request.SessionID = 0xAA
		request.SessionEpoch = 0xEE
		request.AddBlock("topic", 0x12, 0x34, 0x56, 0x66)
		request.RackID = "rack01"
		testRequest(t, "one block v12 flexible", request, fetchRequestOneBlockV12)
	})
}