mirrors/seaweedfs
1
0
Fork 0
mirror of https://github.com/seaweedfs/seaweedfs.git synced 2026-09-30 11:45:42 +00:00
Code Issues Packages Projects Releases Wiki Activity

increase deadline

Browse Source
This commit is contained in:
chrislu
2025-10-14 14:17:57 -07:00
parent 54f4a4285a
commit 4766534b84
1 changed files with 3 additions and 1 deletions
Download Patch File Download Diff File Expand all files Collapse all files
weed/mq/kafka/protocol/fetch.go
+3 -1
View File
@@ -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 {