public static final class CreateConsumerGroupRequest.Builder extends Object
| 限定符和类型 | 方法和说明 |
|---|---|
CreateConsumerGroupRequest |
build() |
CreateConsumerGroupRequest.Builder |
consumerGroup(String consumerGroup)
The name of the consumer group.
|
CreateConsumerGroupRequest.Builder |
logstore(String logstore)
The name of the Logstore.
|
CreateConsumerGroupRequest.Builder |
order(Boolean order)
Specifies whether to consume data in sequence.
|
CreateConsumerGroupRequest.Builder |
project(String project)
The name of the project.
|
CreateConsumerGroupRequest.Builder |
timeout(Integer timeout)
The timeout period.
|
public CreateConsumerGroupRequest.Builder logstore(String logstore)
The name of the Logstore.
This parameter is required.
example:aliyun-test-logstore
public CreateConsumerGroupRequest.Builder project(String project)
The name of the project.
This parameter is required.
example:aliyun-test-project
public CreateConsumerGroupRequest.Builder consumerGroup(String consumerGroup)
The name of the consumer group. The name must be unique in a project.
This parameter is required.
example:consumerGroupX
public CreateConsumerGroupRequest.Builder order(Boolean order)
Specifies whether to consume data in sequence. Valid values:
true
false Data in all shards is consumed at the same time. If a new shard is generated after a shard is split or after shards are merged, data in the new shard is immediately consumed.
This parameter is required.
example:true
public CreateConsumerGroupRequest.Builder timeout(Integer timeout)
The timeout period. If the server does not receive heartbeats from a consumer within the timeout period, the server deletes the consumer. Unit: seconds.
This parameter is required.
example:300
public CreateConsumerGroupRequest build()
Copyright © 2025. All rights reserved.