diff --git a/server/grpc/grpc.go b/server/grpc/grpc.go
index d8a1cb89..53674aa7 100644
--- a/server/grpc/grpc.go
+++ b/server/grpc/grpc.go
@@ -653,7 +653,7 @@ func (g *grpcServer) Register() error {
 			opts = append(opts, broker.DisableAutoAck())
 		}
 
-		log.Logf("Broker [%s] Subscribing to topic: %s", config.Broker.String(), sb.Topic())
+		log.Logf("Subscribing to topic: %s", sb.Topic())
 		sub, err := config.Broker.Subscribe(sb.Topic(), handler, opts...)
 		if err != nil {
 			return err
diff --git a/server/rpc_server.go b/server/rpc_server.go
index 5f7f08d4..a6ccd6a5 100644
--- a/server/rpc_server.go
+++ b/server/rpc_server.go
@@ -654,7 +654,7 @@ func (s *rpcServer) Register() error {
 			opts = append(opts, broker.DisableAutoAck())
 		}
 
-		log.Logf("Broker [%s] Subscribing to topic: %s", config.Broker.String(), sub.Topic())
+		log.Logf("Subscribing to topic: %s", sub.Topic())
 		sub, err := config.Broker.Subscribe(sb.Topic(), s.HandleEvent, opts...)
 		if err != nil {
 			return err