From f5871524be8223862f651612218c96e151824c74 Mon Sep 17 00:00:00 2001 From: chrislu Date: Sat, 13 Sep 2025 19:04:17 -0700 Subject: [PATCH] add debug messages --- weed/mq/kafka/protocol/handler.go | 21 +++++++++++++++++---- 1 file changed, 17 insertions(+), 4 deletions(-) diff --git a/weed/mq/kafka/protocol/handler.go b/weed/mq/kafka/protocol/handler.go index c73ec915d..76a7384b8 100644 --- a/weed/mq/kafka/protocol/handler.go +++ b/weed/mq/kafka/protocol/handler.go @@ -1325,6 +1325,7 @@ func (h *Handler) handleListOffsets(correlationID uint32, apiVersion uint16, req func (h *Handler) handleCreateTopics(correlationID uint32, apiVersion uint16, requestBody []byte) ([]byte, error) { fmt.Printf("DEBUG: *** CREATETOPICS REQUEST RECEIVED *** Correlation: %d, Version: %d\n", correlationID, apiVersion) + fmt.Printf("DEBUG: CreateTopics - Request body size: %d bytes\n", len(requestBody)) if len(requestBody) < 2 { return nil, fmt.Errorf("CreateTopics request too short") @@ -1333,13 +1334,22 @@ func (h *Handler) handleCreateTopics(correlationID uint32, apiVersion uint16, re // Parse based on API version switch apiVersion { case 0, 1: - return h.handleCreateTopicsV0V1(correlationID, requestBody) + fmt.Printf("DEBUG: CreateTopics - Routing to v0/v1 handler\n") + response, err := h.handleCreateTopicsV0V1(correlationID, requestBody) + fmt.Printf("DEBUG: CreateTopics - v0/v1 handler returned, response size: %d bytes, err: %v\n", len(response), err) + return response, err case 2, 3, 4: // kafka-go sends v2-4 in regular format, not compact - return h.handleCreateTopicsV2To4(correlationID, requestBody) + fmt.Printf("DEBUG: CreateTopics - Routing to v2-4 handler\n") + response, err := h.handleCreateTopicsV2To4(correlationID, requestBody) + fmt.Printf("DEBUG: CreateTopics - v2-4 handler returned, response size: %d bytes, err: %v\n", len(response), err) + return response, err case 5: // v5+ uses flexible format with compact arrays - return h.handleCreateTopicsV2Plus(correlationID, apiVersion, requestBody) + fmt.Printf("DEBUG: CreateTopics - Routing to v5+ handler\n") + response, err := h.handleCreateTopicsV2Plus(correlationID, apiVersion, requestBody) + fmt.Printf("DEBUG: CreateTopics - v5+ handler returned, response size: %d bytes, err: %v\n", len(response), err) + return response, err default: return nil, fmt.Errorf("unsupported CreateTopics API version: %d", apiVersion) } @@ -1371,7 +1381,9 @@ func (h *Handler) handleCreateTopicsV2To4(correlationID uint32, requestBody []by if isCompactFormat { fmt.Printf("DEBUG: CreateTopics v2-4 - Detected compact format\n") // Delegate to the compact format handler - return h.handleCreateTopicsV2Plus(correlationID, 2, requestBody) + response, err := h.handleCreateTopicsV2Plus(correlationID, 2, requestBody) + fmt.Printf("DEBUG: CreateTopics v2-4 - Compact format handler returned, response size: %d bytes, err: %v\n", len(response), err) + return response, err } fmt.Printf("DEBUG: CreateTopics v2-4 - Detected regular format\n") @@ -1517,6 +1529,7 @@ func (h *Handler) handleCreateTopicsV2To4(correlationID uint32, requestBody []by response = append(response, 0xFF, 0xFF) } + fmt.Printf("DEBUG: CreateTopics v2-4 - Regular format handler completed, response size: %d bytes\n", len(response)) return response, nil }