public static class CreateEventSourceRequest.CreateEventSourceRequestSourceKafkaParameters
extends com.aliyun.tea.TeaModel
| 限定符和类型 | 字段和说明 |
|---|---|
String |
consumerGroup
The ID of the consumer group that subscribes to the topic.
|
String |
instanceId
The ID of the Message Queue for Apache Kafka instance.
|
Integer |
maximumTasks
The maximum number of consumers.
|
String |
network
The network.
|
String |
offsetReset
The consumer offset.
|
String |
regionId
The ID of the region where the Message Queue for Apache Kafka instance resides.
|
String |
securityGroupId
The ID of the security group to which the Message Queue for Apache Kafka instance belongs.
|
String |
topic
The name of the topic on the Message Queue for Apache Kafka instance.
|
String |
vpcId
The ID of the VPC in which the Message Queue for Apache Kafka instance resides.
|
String |
vSwitchIds
The ID of the vSwitch with which the Message Queue for Apache Kafka instance is associated.
|
| 构造器和说明 |
|---|
CreateEventSourceRequestSourceKafkaParameters() |
@NameInMap(value="ConsumerGroup") public String consumerGroup
The ID of the consumer group that subscribes to the topic.
example:wechat_peer_prod
@NameInMap(value="InstanceId") public String instanceId
The ID of the Message Queue for Apache Kafka instance.
example:pc-2zehmg67txzuyuuwlxv4f
@NameInMap(value="MaximumTasks") public Integer maximumTasks
The maximum number of consumers.
example:1
@NameInMap(value="Network") public String network
The network. Valid values: Default and PublicNetwork. Default value: Default. The value PublicNetwork indicates a self-managed network.
example:Default
@NameInMap(value="OffsetReset") public String offsetReset
The consumer offset.
example:latest
@NameInMap(value="RegionId") public String regionId
The ID of the region where the Message Queue for Apache Kafka instance resides.
example:cn-hangzhou
@NameInMap(value="SecurityGroupId") public String securityGroupId
The ID of the security group to which the Message Queue for Apache Kafka instance belongs. This parameter is required only if you set Network to PublicNetwork.
example:sg-8vbf66aoyp0wfzrzxlmy
@NameInMap(value="Topic") public String topic
The name of the topic on the Message Queue for Apache Kafka instance.
example:prod_ma_dispatch_center_call_record
@NameInMap(value="VSwitchIds") public String vSwitchIds
The ID of the vSwitch with which the Message Queue for Apache Kafka instance is associated. This parameter is required only if you set Network to PublicNetwork.
example:vsw-bp127azpeirmwu4q9ttqi
@NameInMap(value="VpcId") public String vpcId
The ID of the VPC in which the Message Queue for Apache Kafka instance resides. This parameter is required only if you set Network to PublicNetwork.
example:vpc-2ze5ejm986a73qq3vshlk
public CreateEventSourceRequestSourceKafkaParameters()
public static CreateEventSourceRequest.CreateEventSourceRequestSourceKafkaParameters build(Map<String,?> map) throws Exception
Exceptionpublic CreateEventSourceRequest.CreateEventSourceRequestSourceKafkaParameters setConsumerGroup(String consumerGroup)
public String getConsumerGroup()
public CreateEventSourceRequest.CreateEventSourceRequestSourceKafkaParameters setInstanceId(String instanceId)
public String getInstanceId()
public CreateEventSourceRequest.CreateEventSourceRequestSourceKafkaParameters setMaximumTasks(Integer maximumTasks)
public Integer getMaximumTasks()
public CreateEventSourceRequest.CreateEventSourceRequestSourceKafkaParameters setNetwork(String network)
public String getNetwork()
public CreateEventSourceRequest.CreateEventSourceRequestSourceKafkaParameters setOffsetReset(String offsetReset)
public String getOffsetReset()
public CreateEventSourceRequest.CreateEventSourceRequestSourceKafkaParameters setRegionId(String regionId)
public String getRegionId()
public CreateEventSourceRequest.CreateEventSourceRequestSourceKafkaParameters setSecurityGroupId(String securityGroupId)
public String getSecurityGroupId()
public CreateEventSourceRequest.CreateEventSourceRequestSourceKafkaParameters setTopic(String topic)
public String getTopic()
public CreateEventSourceRequest.CreateEventSourceRequestSourceKafkaParameters setVSwitchIds(String vSwitchIds)
public String getVSwitchIds()
public CreateEventSourceRequest.CreateEventSourceRequestSourceKafkaParameters setVpcId(String vpcId)
public String getVpcId()
Copyright © 2026. All rights reserved.