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)))