diff options
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, ",") |