From 0437957db5ab5947cfa43cbe3f727c13cb721d1c Mon Sep 17 00:00:00 2001 From: chrislu Date: Sun, 14 Sep 2025 11:15:33 -0700 Subject: [PATCH] Update offset_management.go --- weed/mq/kafka/protocol/offset_management.go | 5 +++++ 1 file changed, 5 insertions(+) diff --git a/weed/mq/kafka/protocol/offset_management.go b/weed/mq/kafka/protocol/offset_management.go index afd2bf007..03480694d 100644 --- a/weed/mq/kafka/protocol/offset_management.go +++ b/weed/mq/kafka/protocol/offset_management.go @@ -588,6 +588,11 @@ func (h *Handler) buildOffsetFetchResponse(response OffsetFetchResponse, apiVers binary.BigEndian.PutUint32(correlationIDBytes, response.CorrelationID) result = append(result, correlationIDBytes...) + // Throttle time (4 bytes) - for version 3+ this appears immediately after correlation ID + if apiVersion >= 3 { + result = append(result, 0, 0, 0, 0) // throttle_time_ms = 0 + } + // Topics array length (4 bytes) topicsLengthBytes := make([]byte, 4) binary.BigEndian.PutUint32(topicsLengthBytes, uint32(len(response.Topics)))