From 2c525781f8009d3b69615b6037627bc739fea99e Mon Sep 17 00:00:00 2001 From: chrislu Date: Fri, 12 Sep 2025 15:38:51 -0700 Subject: [PATCH] fmt --- weed/mq/kafka/protocol/offset_management.go | 4 ++-- 1 file changed, 2 insertions(+), 2 deletions(-) diff --git a/weed/mq/kafka/protocol/offset_management.go b/weed/mq/kafka/protocol/offset_management.go index a5e853387..e9fe1a847 100644 --- a/weed/mq/kafka/protocol/offset_management.go +++ b/weed/mq/kafka/protocol/offset_management.go @@ -414,7 +414,7 @@ func (h *Handler) parseOffsetFetchRequest(data []byte) (*OffsetFetchRequest, err // Skip client_id (part of OffsetFetch payload) clientIDLength := int(binary.BigEndian.Uint16(data[offset:])) offset += 2 + clientIDLength - fmt.Printf("DEBUG: OffsetFetch skipped client_id (%d bytes: '%s'), offset now: %d\n", + fmt.Printf("DEBUG: OffsetFetch skipped client_id (%d bytes: '%s'), offset now: %d\n", clientIDLength, string(data[2:2+clientIDLength]), offset) // GroupID (string) @@ -427,7 +427,7 @@ func (h *Handler) parseOffsetFetchRequest(data []byte) (*OffsetFetchRequest, err groupID := string(data[offset : offset+groupIDLength]) offset += groupIDLength fmt.Printf("DEBUG: OffsetFetch parsed GroupID: '%s' (len=%d), offset now: %d\n", groupID, groupIDLength, offset) - + // Fix: There's a 1-byte off-by-one error in the offset calculation // This suggests there's an extra byte in the format we're not accounting for offset -= 1