From 4766534b846af7d0040c412a492fcca21f41a717 Mon Sep 17 00:00:00 2001 From: chrislu Date: Tue, 14 Oct 2025 14:17:57 -0700 Subject: [PATCH] increase deadline --- weed/mq/kafka/protocol/fetch.go | 4 +++- 1 file changed, 3 insertions(+), 1 deletion(-) diff --git a/weed/mq/kafka/protocol/fetch.go b/weed/mq/kafka/protocol/fetch.go index edc07d57a..06dba826f 100644 --- a/weed/mq/kafka/protocol/fetch.go +++ b/weed/mq/kafka/protocol/fetch.go @@ -244,7 +244,9 @@ func (h *Handler) handleFetch(ctx context.Context, correlationID uint32, apiVers // Phase 2: Wait for all results with adequate timeout for CI environments // CRITICAL: We MUST return a result for every requested partition or Sarama will error results := make([]*partitionFetchResult, len(pending)) - deadline := time.After(500 * time.Millisecond) // 500ms for all partitions (increased for CI disk I/O) + // Deadline must be longer than subscriber's record batching timeout (1s) to avoid premature timeout + // Add 500ms buffer to account for network and processing overhead + deadline := time.After(1500 * time.Millisecond) // Collect results one by one with shared deadline for i, pf := range pending {