From 0bb866e57c2b4ce27581184cd1f9d035e2cf3a7c Mon Sep 17 00:00:00 2001 From: chrislu Date: Fri, 12 Sep 2025 12:57:05 -0700 Subject: [PATCH] fmt --- weed/mq/kafka/protocol/handler.go | 2 -- 1 file changed, 2 deletions(-) diff --git a/weed/mq/kafka/protocol/handler.go b/weed/mq/kafka/protocol/handler.go index 9935b8893..df46f7013 100644 --- a/weed/mq/kafka/protocol/handler.go +++ b/weed/mq/kafka/protocol/handler.go @@ -156,7 +156,6 @@ func (h *Handler) HandleConn(conn net.Conn) error { conn.Close() }() - r := bufio.NewReader(conn) w := bufio.NewWriter(conn) defer w.Flush() @@ -274,7 +273,6 @@ func (h *Handler) HandleConn(conn net.Conn) error { return fmt.Errorf("handle request: %w", err) } - // Write response size and data responseSizeBytes := make([]byte, 4) binary.BigEndian.PutUint32(responseSizeBytes, uint32(len(response)))