diff options
| -rw-r--r-- | weed/mq/broker/broker_grpc_lookup.go | 5 |
1 files changed, 2 insertions, 3 deletions
diff --git a/weed/mq/broker/broker_grpc_lookup.go b/weed/mq/broker/broker_grpc_lookup.go index 4e9c9e441..ac13a7581 100644 --- a/weed/mq/broker/broker_grpc_lookup.go +++ b/weed/mq/broker/broker_grpc_lookup.go @@ -14,9 +14,8 @@ import ( // // 2. find the topic partitions on the filer // 2.1 if the topic is not found, return error -// 2.2 if the request is_for_publish, create the topic -// 2.2.1 if the request is_for_subscribe, return error not found -// 2.2.2 if the request is_for_publish, create the topic +// 2.1.1 if the request is_for_subscribe, return error not found +// 2.1.2 if the request is_for_publish, create the topic // 2.2 if the topic is found, return the brokers // // 3. unlock the topic |