diff options
| author | chrislu <chris.lu@gmail.com> | 2024-05-20 09:33:37 -0700 |
|---|---|---|
| committer | chrislu <chris.lu@gmail.com> | 2024-05-20 09:33:37 -0700 |
| commit | d8ab22012a1bcaa49de557f05808da3deddcfb1f (patch) | |
| tree | 4129ae83b0adaa65dc63da7b83c1a46fd22d5578 /weed/mq/client/cmd | |
| parent | 2b07a40da5893cba380ac2d9a51e550af6b73e5a (diff) | |
| download | seaweedfs-d8ab22012a1bcaa49de557f05808da3deddcfb1f.tar.xz seaweedfs-d8ab22012a1bcaa49de557f05808da3deddcfb1f.zip | |
track offset
Diffstat (limited to 'weed/mq/client/cmd')
| -rw-r--r-- | weed/mq/client/cmd/weed_sub_kv/subscriber_kv.go | 2 | ||||
| -rw-r--r-- | weed/mq/client/cmd/weed_sub_record/subscriber_record.go | 3 |
2 files changed, 3 insertions, 2 deletions
diff --git a/weed/mq/client/cmd/weed_sub_kv/subscriber_kv.go b/weed/mq/client/cmd/weed_sub_kv/subscriber_kv.go index 5286c229d..4bbb26032 100644 --- a/weed/mq/client/cmd/weed_sub_kv/subscriber_kv.go +++ b/weed/mq/client/cmd/weed_sub_kv/subscriber_kv.go @@ -37,7 +37,7 @@ func main() { } processorConfig := sub_client.ProcessorConfiguration{ - ConcurrentPartitionLimit: 3, + MaxPartitionCount: 3, } brokers := strings.Split(*seedBrokers, ",") diff --git a/weed/mq/client/cmd/weed_sub_record/subscriber_record.go b/weed/mq/client/cmd/weed_sub_record/subscriber_record.go index a5f87a3bb..ed710fa57 100644 --- a/weed/mq/client/cmd/weed_sub_record/subscriber_record.go +++ b/weed/mq/client/cmd/weed_sub_record/subscriber_record.go @@ -63,7 +63,8 @@ func main() { } processorConfig := sub_client.ProcessorConfiguration{ - ConcurrentPartitionLimit: 3, + MaxPartitionCount: 3, + PerPartitionConcurrency: 1, } brokers := strings.Split(*seedBrokers, ",") |