diff --git a/pkg/queue/queue.go b/pkg/queue/queue.go index aab4631e86e4f..006106aa44a61 100644 --- a/pkg/queue/queue.go +++ b/pkg/queue/queue.go @@ -139,7 +139,7 @@ func (q *RequestQueue) ReleaseRequests(items []Request) { // The caller is responsible for returning the dequeued requests back to the // pool by calling ReleaseRequests(items). func (q *RequestQueue) DequeueMany(ctx context.Context, last QueueIndex, consumerID string, maxItems int, maxWait time.Duration) ([]Request, QueueIndex, error) { - // create a context for dequeuing with a max time we want to wait to fullfill the desired maxItems + // create a context for dequeuing with a max time we want to wait to fulfill the desired maxItems dequeueCtx, cancel := context.WithTimeout(ctx, maxWait) defer cancel()