go fmt

3 files changed, 2 insertions, 2 deletions

diff --git a/weed/messaging/msgclient/client.go b/weed/messaging/msgclient/client.go
index f4e11232e..4d7ef2b8e 100644
--- a/weed/messaging/msgclient/client.go
+++ b/weed/messaging/msgclient/client.go
@@ -28,7 +28,6 @@ func NewMessagingClient(bootstrapBrokers ...string) *MessagingClient {
 	}
 }
 
-
 func (mc *MessagingClient) findBroker(tp broker.TopicPartition) (*grpc.ClientConn, error) {
 
 	for _, broker := range mc.bootstrapBrokers {
diff --git a/weed/messaging/msgclient/publisher.go b/weed/messaging/msgclient/publisher.go
index 08f1d278a..ebb6d3f2a 100644
--- a/weed/messaging/msgclient/publisher.go
+++ b/weed/messaging/msgclient/publisher.go
@@ -16,6 +16,7 @@ type Publisher struct {
 	messageCount       uint64
 	publisherId        string
 }
+
 /*
 func (mc *MessagingClient) NewPublisher(publisherId, namespace, topic string) (*Publisher, error) {
 	// read topic configuration
diff --git a/weed/messaging/msgclient/subscriber.go b/weed/messaging/msgclient/subscriber.go
index d3066d6ef..efbfa0337 100644
--- a/weed/messaging/msgclient/subscriber.go
+++ b/weed/messaging/msgclient/subscriber.go
@@ -5,8 +5,8 @@ import (
 	"io"
 	"time"
 
-	"google.golang.org/grpc"
 	"github.com/chrislusf/seaweedfs/weed/pb/messaging_pb"
+	"google.golang.org/grpc"
 )
 
 type Subscriber struct {