diff options
| author | chrislu <chris.lu@gmail.com> | 2023-12-22 11:33:00 -0800 |
|---|---|---|
| committer | chrislu <chris.lu@gmail.com> | 2023-12-22 11:33:00 -0800 |
| commit | 034db049a080d9a07a8527894e0aa58e8412207e (patch) | |
| tree | 90d349e8c087f261036e50941580e24fbf7488dd | |
| parent | 6df44d3c95219d695bf13a90c21f01cb9d5108aa (diff) | |
| download | seaweedfs-034db049a080d9a07a8527894e0aa58e8412207e.tar.xz seaweedfs-034db049a080d9a07a8527894e0aa58e8412207e.zip | |
comment fix
| -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 |