diff options
Diffstat (limited to 'weed/mq/broker/broker_grpc_configure.go')
| -rw-r--r-- | weed/mq/broker/broker_grpc_configure.go | 2 |
1 files changed, 1 insertions, 1 deletions
diff --git a/weed/mq/broker/broker_grpc_configure.go b/weed/mq/broker/broker_grpc_configure.go index 892a43007..fb916d880 100644 --- a/weed/mq/broker/broker_grpc_configure.go +++ b/weed/mq/broker/broker_grpc_configure.go @@ -66,7 +66,7 @@ func (b *MessageQueueBroker) ConfigureTopic(ctx context.Context, request *mq_pb. // save the topic configuration on filer if err := b.fca.SaveTopicConfToFiler(t, resp); err != nil { - return nil, fmt.Errorf("configure topic: %v", err) + return nil, fmt.Errorf("configure topic: %w", err) } b.PubBalancer.OnPartitionChange(request.Topic, resp.BrokerPartitionAssignments) |