public static class GetEventStreamingResponseBody.GetEventStreamingResponseBodyDataSourceSourceRocketMQParameters
extends com.aliyun.tea.TeaModel
| 限定符和类型 | 字段和说明 |
|---|---|
String |
authType
example:
ACL
|
String |
bodyDataType
example:
Json
|
String |
filterSql
example:
index > 10
|
String |
filterType
example:
Tag
|
String |
groupID
The ID of the consumer group in the Message Queue for Apache RocketMQ instance.
|
String |
instanceEndpoint
example:
reg****-vpc.cn-zhangjiakou.aliyuncs.com
|
String |
instanceId
The ID of the Message Queue for Apache RocketMQ instance.
|
String |
instanceNetwork
example:
PublicNetwork
|
String |
instancePassword
example:
xxxa
|
String |
instanceSecurityGroupId
example:
sg-m5edtu24f12345****
|
String |
instanceType
example:
2
|
String |
instanceUsername
example:
xxxa
|
String |
instanceVpcId
example:
vpc-m5e3sv4b12345****
|
String |
instanceVSwitchIds
example:
vsw-m5ev8asdc6h12****
|
String |
network
example:
PublicNetwork
|
String |
offset
The consumer offset of messages.
|
String |
regionId
The region ID of the Message Queue for Apache RocketMQ instance.
|
String |
securityGroupId
example:
sg-m5edtu24f12345****
|
String |
tag
The tags that are used to filter messages.
|
Long |
timestamp
The timestamp of the offset from which consumption starts.
|
String |
topic
The topic to which the message belongs.
|
String |
vpcId
example:
vpc-m5e3sv4b12345****
|
String |
vSwitchIds
example:
vsw-m5ev8asdc6h12345****
|
| 构造器和说明 |
|---|
GetEventStreamingResponseBodyDataSourceSourceRocketMQParameters() |
@NameInMap(value="AuthType") public String authType
ACL
@NameInMap(value="BodyDataType") public String bodyDataType
Json
@NameInMap(value="FilterSql") public String filterSql
index > 10
@NameInMap(value="FilterType") public String filterType
Tag
@NameInMap(value="GroupID") public String groupID
The ID of the consumer group in the Message Queue for Apache RocketMQ instance.
example:GID_group1
@NameInMap(value="InstanceEndpoint") public String instanceEndpoint
reg****-vpc.cn-zhangjiakou.aliyuncs.com
@NameInMap(value="InstanceId") public String instanceId
The ID of the Message Queue for Apache RocketMQ instance.
example:i-f8zbher64dlm58plyfte
@NameInMap(value="InstanceNetwork") public String instanceNetwork
PublicNetwork
@NameInMap(value="InstancePassword") public String instancePassword
xxxa
@NameInMap(value="InstanceSecurityGroupId") public String instanceSecurityGroupId
sg-m5edtu24f12345****
@NameInMap(value="InstanceType") public String instanceType
2
@NameInMap(value="InstanceUsername") public String instanceUsername
xxxa
@NameInMap(value="InstanceVSwitchIds") public String instanceVSwitchIds
vsw-m5ev8asdc6h12****
@NameInMap(value="InstanceVpcId") public String instanceVpcId
vpc-m5e3sv4b12345****
@NameInMap(value="Network") public String network
PublicNetwork
@NameInMap(value="Offset") public String offset
The consumer offset of messages. Valid values: CONSUME_FROM_LAST_OFFSET: Start consumption from the latest offset. CONSUME_FROM_FIRST_OFFSET: Start consumption from the earliest offset. CONSUME_FROM_TIMESTAMP: Start consumption from the offset at the specified point in time.
example:CONSUMEFROMLASTOFFSET
@NameInMap(value="RegionId") public String regionId
The region ID of the Message Queue for Apache RocketMQ instance.
example:cn-hangzhou
@NameInMap(value="SecurityGroupId") public String securityGroupId
sg-m5edtu24f12345****
@NameInMap(value="Tag") public String tag
The tags that are used to filter messages.
example:v1
@NameInMap(value="Timestamp") public Long timestamp
The timestamp of the offset from which consumption starts. This parameter is valid only if you set the Offset parameter to CONSUME_FROM_TIMESTAMP.
example:1636597951964
@NameInMap(value="Topic") public String topic
The topic to which the message belongs.
example:topic_add_anima
@NameInMap(value="VSwitchIds") public String vSwitchIds
vsw-m5ev8asdc6h12345****
@NameInMap(value="VpcId") public String vpcId
vpc-m5e3sv4b12345****
public GetEventStreamingResponseBodyDataSourceSourceRocketMQParameters()
public static GetEventStreamingResponseBody.GetEventStreamingResponseBodyDataSourceSourceRocketMQParameters build(Map<String,?> map) throws Exception
Exceptionpublic GetEventStreamingResponseBody.GetEventStreamingResponseBodyDataSourceSourceRocketMQParameters setAuthType(String authType)
public String getAuthType()
public GetEventStreamingResponseBody.GetEventStreamingResponseBodyDataSourceSourceRocketMQParameters setBodyDataType(String bodyDataType)
public String getBodyDataType()
public GetEventStreamingResponseBody.GetEventStreamingResponseBodyDataSourceSourceRocketMQParameters setFilterSql(String filterSql)
public String getFilterSql()
public GetEventStreamingResponseBody.GetEventStreamingResponseBodyDataSourceSourceRocketMQParameters setFilterType(String filterType)
public String getFilterType()
public GetEventStreamingResponseBody.GetEventStreamingResponseBodyDataSourceSourceRocketMQParameters setGroupID(String groupID)
public String getGroupID()
public GetEventStreamingResponseBody.GetEventStreamingResponseBodyDataSourceSourceRocketMQParameters setInstanceEndpoint(String instanceEndpoint)
public String getInstanceEndpoint()
public GetEventStreamingResponseBody.GetEventStreamingResponseBodyDataSourceSourceRocketMQParameters setInstanceId(String instanceId)
public String getInstanceId()
public GetEventStreamingResponseBody.GetEventStreamingResponseBodyDataSourceSourceRocketMQParameters setInstanceNetwork(String instanceNetwork)
public String getInstanceNetwork()
public GetEventStreamingResponseBody.GetEventStreamingResponseBodyDataSourceSourceRocketMQParameters setInstancePassword(String instancePassword)
public String getInstancePassword()
public GetEventStreamingResponseBody.GetEventStreamingResponseBodyDataSourceSourceRocketMQParameters setInstanceSecurityGroupId(String instanceSecurityGroupId)
public String getInstanceSecurityGroupId()
public GetEventStreamingResponseBody.GetEventStreamingResponseBodyDataSourceSourceRocketMQParameters setInstanceType(String instanceType)
public String getInstanceType()
public GetEventStreamingResponseBody.GetEventStreamingResponseBodyDataSourceSourceRocketMQParameters setInstanceUsername(String instanceUsername)
public String getInstanceUsername()
public GetEventStreamingResponseBody.GetEventStreamingResponseBodyDataSourceSourceRocketMQParameters setInstanceVSwitchIds(String instanceVSwitchIds)
public String getInstanceVSwitchIds()
public GetEventStreamingResponseBody.GetEventStreamingResponseBodyDataSourceSourceRocketMQParameters setInstanceVpcId(String instanceVpcId)
public String getInstanceVpcId()
public GetEventStreamingResponseBody.GetEventStreamingResponseBodyDataSourceSourceRocketMQParameters setNetwork(String network)
public String getNetwork()
public GetEventStreamingResponseBody.GetEventStreamingResponseBodyDataSourceSourceRocketMQParameters setOffset(String offset)
public String getOffset()
public GetEventStreamingResponseBody.GetEventStreamingResponseBodyDataSourceSourceRocketMQParameters setRegionId(String regionId)
public String getRegionId()
public GetEventStreamingResponseBody.GetEventStreamingResponseBodyDataSourceSourceRocketMQParameters setSecurityGroupId(String securityGroupId)
public String getSecurityGroupId()
public GetEventStreamingResponseBody.GetEventStreamingResponseBodyDataSourceSourceRocketMQParameters setTag(String tag)
public String getTag()
public GetEventStreamingResponseBody.GetEventStreamingResponseBodyDataSourceSourceRocketMQParameters setTimestamp(Long timestamp)
public Long getTimestamp()
public GetEventStreamingResponseBody.GetEventStreamingResponseBodyDataSourceSourceRocketMQParameters setTopic(String topic)
public String getTopic()
public GetEventStreamingResponseBody.GetEventStreamingResponseBodyDataSourceSourceRocketMQParameters setVSwitchIds(String vSwitchIds)
public String getVSwitchIds()
public GetEventStreamingResponseBody.GetEventStreamingResponseBodyDataSourceSourceRocketMQParameters setVpcId(String vpcId)
public String getVpcId()
Copyright © 2026. All rights reserved.