diff options
| author | chrislu <chris.lu@gmail.com> | 2022-07-03 00:55:37 -0700 |
|---|---|---|
| committer | chrislu <chris.lu@gmail.com> | 2022-07-28 23:22:52 -0700 |
| commit | f25e273e328a9959f4dcef13c5f78e427c0bf7a0 (patch) | |
| tree | 66168b00670b2dc0d8a52f42395b3e9918c2e657 /weed/mq | |
| parent | 68065128b83997365a0f267799026b0e520b9816 (diff) | |
| download | seaweedfs-f25e273e328a9959f4dcef13c5f78e427c0bf7a0.tar.xz seaweedfs-f25e273e328a9959f4dcef13c5f78e427c0bf7a0.zip | |
display data center and rack in cluster.ps
Diffstat (limited to 'weed/mq')
| -rw-r--r-- | weed/mq/broker/broker_server.go | 2 |
1 files changed, 1 insertions, 1 deletions
diff --git a/weed/mq/broker/broker_server.go b/weed/mq/broker/broker_server.go index 1887498d2..36f216a48 100644 --- a/weed/mq/broker/broker_server.go +++ b/weed/mq/broker/broker_server.go @@ -41,7 +41,7 @@ func NewMessageBroker(option *MessageQueueBrokerOption, grpcDialOption grpc.Dial mqBroker = &MessageQueueBroker{ option: option, grpcDialOption: grpcDialOption, - MasterClient: wdclient.NewMasterClient(grpcDialOption, option.FilerGroup, cluster.BrokerType, pb.NewServerAddress(option.Ip, option.Port, 0), option.DataCenter, "", option.Masters), + MasterClient: wdclient.NewMasterClient(grpcDialOption, option.FilerGroup, cluster.BrokerType, pb.NewServerAddress(option.Ip, option.Port, 0), option.DataCenter, option.Rack, option.Masters), } mqBroker.topicManager = NewTopicManager(mqBroker) |