Function TestOffsetRequestV4

offset_request_test.go:104–110

(t *testing.T)

}

func TestOffsetRequestV4(t *testing.T) {
	request := new(OffsetRequest)
	request.Version = 4
	request.IsolationLevel = ReadCommitted
	request.AddBlock("dnwe", 9, -1, -1)
	testRequest(t, "V4", request, offsetRequestV4)
}