fmt

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