public static class CreateEventStreamingRequest.CreateEventStreamingRequestSourceSourceKafkaParameters
extends com.aliyun.tea.TeaModel
| 限定符和类型 | 字段和说明 |
|---|---|
String |
consumerGroup
The group ID of the consumer that subscribes to the topic.
|
String |
instanceId
The ID of the ApsaraMQ for Kafka instance.
|
String |
network
The network type.
|
String |
offsetReset
The offset from which messages are consumed.
|
String |
regionId
The ID of the region where the ApsaraMQ for Kafka instance resides.
|
String |
securityGroupId
The ID of the security group to which the ApsaraMQ for Kafka instance belongs.
|
String |
topic
The name of the topic on the ApsaraMQ for Kafka instance.
|
String |
valueDataType
example:
JSON
|
String |
vpcId
The ID of the VPC to which the ApsaraMQ for Kafka instance belongs.
|
String |
vSwitchIds
The ID of the vSwitch with which the ApsaraMQ for Kafka instance is associated.
|
| 构造器和说明 |
|---|
CreateEventStreamingRequestSourceSourceKafkaParameters() |
@NameInMap(value="ConsumerGroup") public String consumerGroup
The group ID of the consumer that subscribes to the topic.
example:DEFAULT_GROUP
@NameInMap(value="InstanceId") public String instanceId
The ID of the ApsaraMQ for Kafka instance.
example:r-8vb64581862cd814
@NameInMap(value="Network") public String network
The network type. Default value: Default. The value PublicNetwork specifies a virtual private cloud (VPC).
example:Default
@NameInMap(value="OffsetReset") public String offsetReset
The offset from which messages are consumed.
example:latest
@NameInMap(value="RegionId") public String regionId
The ID of the region where the ApsaraMQ for Kafka instance resides.
example:cn-hangzhou
@NameInMap(value="SecurityGroupId") public String securityGroupId
The ID of the security group to which the ApsaraMQ for Kafka instance belongs.
example:sg-bp1iv19sp1msc7zot4wr
@NameInMap(value="Topic") public String topic
The name of the topic on the ApsaraMQ for Kafka instance.
example:popvip_center_robot_order
@NameInMap(value="VSwitchIds") public String vSwitchIds
The ID of the vSwitch with which the ApsaraMQ for Kafka instance is associated.
example:vsw-bp179l3llg3jjxwrq72hh
@NameInMap(value="ValueDataType") public String valueDataType
JSON
@NameInMap(value="VpcId") public String vpcId
The ID of the VPC to which the ApsaraMQ for Kafka instance belongs.
example:vpc-8vblalsi0vbhizr77cbhu
public CreateEventStreamingRequestSourceSourceKafkaParameters()
public static CreateEventStreamingRequest.CreateEventStreamingRequestSourceSourceKafkaParameters build(Map<String,?> map) throws Exception
Exceptionpublic CreateEventStreamingRequest.CreateEventStreamingRequestSourceSourceKafkaParameters setConsumerGroup(String consumerGroup)
public String getConsumerGroup()
public CreateEventStreamingRequest.CreateEventStreamingRequestSourceSourceKafkaParameters setInstanceId(String instanceId)
public String getInstanceId()
public CreateEventStreamingRequest.CreateEventStreamingRequestSourceSourceKafkaParameters setNetwork(String network)
public String getNetwork()
public CreateEventStreamingRequest.CreateEventStreamingRequestSourceSourceKafkaParameters setOffsetReset(String offsetReset)
public String getOffsetReset()
public CreateEventStreamingRequest.CreateEventStreamingRequestSourceSourceKafkaParameters setRegionId(String regionId)
public String getRegionId()
public CreateEventStreamingRequest.CreateEventStreamingRequestSourceSourceKafkaParameters setSecurityGroupId(String securityGroupId)
public String getSecurityGroupId()
public CreateEventStreamingRequest.CreateEventStreamingRequestSourceSourceKafkaParameters setTopic(String topic)
public String getTopic()
public CreateEventStreamingRequest.CreateEventStreamingRequestSourceSourceKafkaParameters setVSwitchIds(String vSwitchIds)
public String getVSwitchIds()
public CreateEventStreamingRequest.CreateEventStreamingRequestSourceSourceKafkaParameters setValueDataType(String valueDataType)
public String getValueDataType()
public CreateEventStreamingRequest.CreateEventStreamingRequestSourceSourceKafkaParameters setVpcId(String vpcId)
public String getVpcId()
Copyright © 2026. All rights reserved.