public static class GetEventStreamingResponseBody.GetEventStreamingResponseBodyDataSourceSourceKafkaParameters
extends com.aliyun.tea.TeaModel
| 限定符和类型 | 字段和说明 |
|---|---|
String |
consumerGroup
The ID of the consumer group that subscribes to the topic.
|
String |
instanceId
The instance ID.
|
String |
network
The network.
|
String |
offsetReset
The offset.
|
String |
regionId
The region ID of the Message Queue for Apache Kafka instance.
|
String |
securityGroupId
The security group ID.
|
String |
topic
The name of the topic.
|
String |
valueDataType
The encoding or decoding format.
|
String |
vpcId
The ID of the virtual private cloud (VPC).
|
String |
vSwitchIds
The vSwitch ID.
|
| 构造器和说明 |
|---|
GetEventStreamingResponseBodyDataSourceSourceKafkaParameters() |
@NameInMap(value="ConsumerGroup") public String consumerGroup
The ID of the consumer group that subscribes to the topic.
example:GID_TEST
@NameInMap(value="InstanceId") public String instanceId
The instance ID.
example:i-bp1fbtrnqmjvgq66ajdw
@NameInMap(value="Network") public String network
The network. Default value: Default. The value PublicNetwork specifies a virtual private cloud (VPC).
example:Default
@NameInMap(value="OffsetReset") public String offsetReset
The offset.
example:latest
@NameInMap(value="RegionId") public String regionId
The region ID of the Message Queue for Apache Kafka instance.
example:cn-hangzhou
@NameInMap(value="SecurityGroupId") public String securityGroupId
The security group ID.
example:sg-2vcgdxz7o1n9zappuimt
@NameInMap(value="Topic") public String topic
The name of the topic.
example:topic_empower_1642473600414
@NameInMap(value="VSwitchIds") public String vSwitchIds
The vSwitch ID.
example:vsw-wz9qqeovkwjxlu9uc8rst
@NameInMap(value="ValueDataType") public String valueDataType
The encoding or decoding format. Valid values: Json, Text, and Binary. The value Json indicates that bytes are decoded into UTF-8 strings and then parsed into JSON format. The value Text indicates that bytes are decoded into UTF-8 strings and then put into the payload. The value Binary indicates that bytes are encoded into Base64 strings and put into the payload.
example:Text
@NameInMap(value="VpcId") public String vpcId
The ID of the virtual private cloud (VPC).
example:vpc-2zehizpoendb3nwwu9w5o
public GetEventStreamingResponseBodyDataSourceSourceKafkaParameters()
public static GetEventStreamingResponseBody.GetEventStreamingResponseBodyDataSourceSourceKafkaParameters build(Map<String,?> map) throws Exception
Exceptionpublic GetEventStreamingResponseBody.GetEventStreamingResponseBodyDataSourceSourceKafkaParameters setConsumerGroup(String consumerGroup)
public String getConsumerGroup()
public GetEventStreamingResponseBody.GetEventStreamingResponseBodyDataSourceSourceKafkaParameters setInstanceId(String instanceId)
public String getInstanceId()
public GetEventStreamingResponseBody.GetEventStreamingResponseBodyDataSourceSourceKafkaParameters setNetwork(String network)
public String getNetwork()
public GetEventStreamingResponseBody.GetEventStreamingResponseBodyDataSourceSourceKafkaParameters setOffsetReset(String offsetReset)
public String getOffsetReset()
public GetEventStreamingResponseBody.GetEventStreamingResponseBodyDataSourceSourceKafkaParameters setRegionId(String regionId)
public String getRegionId()
public GetEventStreamingResponseBody.GetEventStreamingResponseBodyDataSourceSourceKafkaParameters setSecurityGroupId(String securityGroupId)
public String getSecurityGroupId()
public GetEventStreamingResponseBody.GetEventStreamingResponseBodyDataSourceSourceKafkaParameters setTopic(String topic)
public String getTopic()
public GetEventStreamingResponseBody.GetEventStreamingResponseBodyDataSourceSourceKafkaParameters setVSwitchIds(String vSwitchIds)
public String getVSwitchIds()
public GetEventStreamingResponseBody.GetEventStreamingResponseBodyDataSourceSourceKafkaParameters setValueDataType(String valueDataType)
public String getValueDataType()
public GetEventStreamingResponseBody.GetEventStreamingResponseBodyDataSourceSourceKafkaParameters setVpcId(String vpcId)
public String getVpcId()
Copyright © 2026. All rights reserved.