From 4bf914e27432e403903cde275347d95b68e42dc1 Mon Sep 17 00:00:00 2001 From: chrislu Date: Thu, 16 Oct 2025 10:42:18 -0700 Subject: [PATCH] clean up --- weed/mq/kafka/protocol/find_coordinator.go | 10 ---------- 1 file changed, 10 deletions(-) diff --git a/weed/mq/kafka/protocol/find_coordinator.go b/weed/mq/kafka/protocol/find_coordinator.go index f50f23e55..8b533486d 100644 --- a/weed/mq/kafka/protocol/find_coordinator.go +++ b/weed/mq/kafka/protocol/find_coordinator.go @@ -48,11 +48,6 @@ func (h *Handler) handleFindCoordinator(correlationID uint32, apiVersion uint16, func (h *Handler) handleFindCoordinatorV0(correlationID uint32, requestBody []byte) ([]byte, error) { // Parse FindCoordinator v0 request: Key (STRING) only - dumpLen := len(requestBody) - if dumpLen > 50 { - dumpLen = 50 - } - if len(requestBody) < 2 { // need at least Key length return nil, fmt.Errorf("FindCoordinator request too short") } @@ -127,11 +122,6 @@ func (h *Handler) handleFindCoordinatorV0(correlationID uint32, requestBody []by func (h *Handler) handleFindCoordinatorV2(correlationID uint32, requestBody []byte) ([]byte, error) { // Parse FindCoordinator request (v0-2 non-flex): Key (STRING), v1+ adds KeyType (INT8) - dumpLen := len(requestBody) - if dumpLen > 50 { - dumpLen = 50 - } - if len(requestBody) < 2 { // need at least Key length return nil, fmt.Errorf("FindCoordinator request too short") }