fmt

weed/mq/broker/broker_server.go

@@ -2,13 +2,14 @@ package broker
 
 import (
 	"context"
+	"sync"
+	"time"
+
 	"github.com/seaweedfs/seaweedfs/weed/filer_client"
 	"github.com/seaweedfs/seaweedfs/weed/glog"
 	"github.com/seaweedfs/seaweedfs/weed/mq/pub_balancer"
 	"github.com/seaweedfs/seaweedfs/weed/mq/sub_coordinator"
 	"github.com/seaweedfs/seaweedfs/weed/mq/topic"
-	"sync"
-	"time"
 
 	"github.com/seaweedfs/seaweedfs/weed/cluster"
 	"github.com/seaweedfs/seaweedfs/weed/pb/mq_pb"

weed/mq/sub_coordinator/sub_coordinator.go

@@ -2,6 +2,7 @@ package sub_coordinator
 
 import (
 	"fmt"
+
 	cmap "github.com/orcaman/concurrent-map/v2"
 	"github.com/seaweedfs/seaweedfs/weed/filer_client"
 	"github.com/seaweedfs/seaweedfs/weed/pb/mq_pb"

weed/mq/topic/local_manager.go

@@ -1,11 +1,12 @@
 package topic
 
 import (
+	"time"
+
 	cmap "github.com/orcaman/concurrent-map/v2"
 	"github.com/seaweedfs/seaweedfs/weed/pb/mq_pb"
 	"github.com/seaweedfs/seaweedfs/weed/pb/schema_pb"
 	"github.com/shirou/gopsutil/v3/cpu"
-	"time"
 )
 
 // LocalTopicManager manages topics on local broker