com.aliyun.eventbridge20200401.models

类 CreateEventStreamingRequest.CreateEventStreamingRequestSinkSinkKafkaParameters

java.lang.Object

com.aliyun.tea.TeaModel

com.aliyun.eventbridge20200401.models.CreateEventStreamingRequest.CreateEventStreamingRequestSinkSinkKafkaParameters

封闭类:

CreateEventStreamingRequest

public static class CreateEventStreamingRequest.CreateEventStreamingRequestSinkSinkKafkaParameters
extends com.aliyun.tea.TeaModel

字段概要

字段

限定符和类型	字段和说明
CreateEventStreamingRequest.CreateEventStreamingRequestSinkSinkKafkaParametersAcks	acks The acknowledgment (ACK) mode.
String	compressionType
CreateEventStreamingRequest.CreateEventStreamingRequestSinkSinkKafkaParametersDynamicTopic	dynamicTopic
CreateEventStreamingRequest.CreateEventStreamingRequestSinkSinkKafkaParametersHeaders	headers
CreateEventStreamingRequest.CreateEventStreamingRequestSinkSinkKafkaParametersInstanceId	instanceId The ID of the ApsaraMQ for Kafka instance.
CreateEventStreamingRequest.CreateEventStreamingRequestSinkSinkKafkaParametersKey	key The message key.
CreateEventStreamingRequest.CreateEventStreamingRequestSinkSinkKafkaParametersTopic	topic The name of the topic on the ApsaraMQ for Kafka instance.
CreateEventStreamingRequest.CreateEventStreamingRequestSinkSinkKafkaParametersValue	value The message body.

构造器概要

构造器

构造器和说明
CreateEventStreamingRequestSinkSinkKafkaParameters()

方法概要

限定符和类型	方法和说明
static CreateEventStreamingRequest.CreateEventStreamingRequestSinkSinkKafkaParameters	build(Map<String,?> map)
CreateEventStreamingRequest.CreateEventStreamingRequestSinkSinkKafkaParametersAcks	getAcks()
String	getCompressionType()
CreateEventStreamingRequest.CreateEventStreamingRequestSinkSinkKafkaParametersDynamicTopic	getDynamicTopic()
CreateEventStreamingRequest.CreateEventStreamingRequestSinkSinkKafkaParametersHeaders	getHeaders()
CreateEventStreamingRequest.CreateEventStreamingRequestSinkSinkKafkaParametersInstanceId	getInstanceId()
CreateEventStreamingRequest.CreateEventStreamingRequestSinkSinkKafkaParametersKey	getKey()
CreateEventStreamingRequest.CreateEventStreamingRequestSinkSinkKafkaParametersTopic	getTopic()
CreateEventStreamingRequest.CreateEventStreamingRequestSinkSinkKafkaParametersValue	getValue()
CreateEventStreamingRequest.CreateEventStreamingRequestSinkSinkKafkaParameters	setAcks(CreateEventStreamingRequest.CreateEventStreamingRequestSinkSinkKafkaParametersAcks acks)
CreateEventStreamingRequest.CreateEventStreamingRequestSinkSinkKafkaParameters	setCompressionType(String compressionType)
CreateEventStreamingRequest.CreateEventStreamingRequestSinkSinkKafkaParameters	setDynamicTopic(CreateEventStreamingRequest.CreateEventStreamingRequestSinkSinkKafkaParametersDynamicTopic dynamicTopic)
CreateEventStreamingRequest.CreateEventStreamingRequestSinkSinkKafkaParameters	setHeaders(CreateEventStreamingRequest.CreateEventStreamingRequestSinkSinkKafkaParametersHeaders headers)
CreateEventStreamingRequest.CreateEventStreamingRequestSinkSinkKafkaParameters	setInstanceId(CreateEventStreamingRequest.CreateEventStreamingRequestSinkSinkKafkaParametersInstanceId instanceId)
CreateEventStreamingRequest.CreateEventStreamingRequestSinkSinkKafkaParameters	setKey(CreateEventStreamingRequest.CreateEventStreamingRequestSinkSinkKafkaParametersKey key)
CreateEventStreamingRequest.CreateEventStreamingRequestSinkSinkKafkaParameters	setTopic(CreateEventStreamingRequest.CreateEventStreamingRequestSinkSinkKafkaParametersTopic topic)
CreateEventStreamingRequest.CreateEventStreamingRequestSinkSinkKafkaParameters	setValue(CreateEventStreamingRequest.CreateEventStreamingRequestSinkSinkKafkaParametersValue value)

从类继承的方法 com.aliyun.tea.TeaModel

build, buildMap, confirmType, confirmType, parseObject, toMap, toMap, toModel, validate, validateParams

从类继承的方法 java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

字段详细资料

acks

@NameInMap(value="Acks")
public CreateEventStreamingRequest.CreateEventStreamingRequestSinkSinkKafkaParametersAcks acks

The acknowledgment (ACK) mode.

• If you set this parameter to 0, no response is returned from the broker. In this mode, the performance is high, but the risk of data loss is also high.
• If you set this parameter to 1, a response is returned when data is written to the leader. In this mode, the performance and the risk of data loss are moderate. Data loss may occur if a failure occurs on the leader.
• If you set this parameter to all, a response is returned when data is written to the leader and synchronized to the followers. In this mode, the performance is low, but the risk of data loss is also low. Data loss occurs if the leader and the followers fail at the same time.

compressionType

@NameInMap(value="CompressionType")
public String compressionType

dynamicTopic

@NameInMap(value="DynamicTopic")
public CreateEventStreamingRequest.CreateEventStreamingRequestSinkSinkKafkaParametersDynamicTopic dynamicTopic

headers

@NameInMap(value="Headers")
public CreateEventStreamingRequest.CreateEventStreamingRequestSinkSinkKafkaParametersHeaders headers

instanceId

@NameInMap(value="InstanceId")
public CreateEventStreamingRequest.CreateEventStreamingRequestSinkSinkKafkaParametersInstanceId instanceId

The ID of the ApsaraMQ for Kafka instance.

key

@NameInMap(value="Key")
public CreateEventStreamingRequest.CreateEventStreamingRequestSinkSinkKafkaParametersKey key

The message key.

topic

@NameInMap(value="Topic")
public CreateEventStreamingRequest.CreateEventStreamingRequestSinkSinkKafkaParametersTopic topic

The name of the topic on the ApsaraMQ for Kafka instance.

value

@NameInMap(value="Value")
public CreateEventStreamingRequest.CreateEventStreamingRequestSinkSinkKafkaParametersValue value

The message body.

构造器详细资料

CreateEventStreamingRequestSinkSinkKafkaParameters

public CreateEventStreamingRequestSinkSinkKafkaParameters()

方法详细资料

build

public static CreateEventStreamingRequest.CreateEventStreamingRequestSinkSinkKafkaParameters build(Map<String,?> map)
                                                                                            throws Exception

抛出:

Exception

setAcks

public CreateEventStreamingRequest.CreateEventStreamingRequestSinkSinkKafkaParameters setAcks(CreateEventStreamingRequest.CreateEventStreamingRequestSinkSinkKafkaParametersAcks acks)

getAcks

public CreateEventStreamingRequest.CreateEventStreamingRequestSinkSinkKafkaParametersAcks getAcks()

setCompressionType

public CreateEventStreamingRequest.CreateEventStreamingRequestSinkSinkKafkaParameters setCompressionType(String compressionType)

getCompressionType

public String getCompressionType()

setDynamicTopic

public CreateEventStreamingRequest.CreateEventStreamingRequestSinkSinkKafkaParameters setDynamicTopic(CreateEventStreamingRequest.CreateEventStreamingRequestSinkSinkKafkaParametersDynamicTopic dynamicTopic)

getDynamicTopic

public CreateEventStreamingRequest.CreateEventStreamingRequestSinkSinkKafkaParametersDynamicTopic getDynamicTopic()

setHeaders

public CreateEventStreamingRequest.CreateEventStreamingRequestSinkSinkKafkaParameters setHeaders(CreateEventStreamingRequest.CreateEventStreamingRequestSinkSinkKafkaParametersHeaders headers)

getHeaders

public CreateEventStreamingRequest.CreateEventStreamingRequestSinkSinkKafkaParametersHeaders getHeaders()

setInstanceId

public CreateEventStreamingRequest.CreateEventStreamingRequestSinkSinkKafkaParameters setInstanceId(CreateEventStreamingRequest.CreateEventStreamingRequestSinkSinkKafkaParametersInstanceId instanceId)

getInstanceId

public CreateEventStreamingRequest.CreateEventStreamingRequestSinkSinkKafkaParametersInstanceId getInstanceId()

setKey

public CreateEventStreamingRequest.CreateEventStreamingRequestSinkSinkKafkaParameters setKey(CreateEventStreamingRequest.CreateEventStreamingRequestSinkSinkKafkaParametersKey key)

getKey

public CreateEventStreamingRequest.CreateEventStreamingRequestSinkSinkKafkaParametersKey getKey()

setTopic

public CreateEventStreamingRequest.CreateEventStreamingRequestSinkSinkKafkaParameters setTopic(CreateEventStreamingRequest.CreateEventStreamingRequestSinkSinkKafkaParametersTopic topic)

getTopic

public CreateEventStreamingRequest.CreateEventStreamingRequestSinkSinkKafkaParametersTopic getTopic()

setValue

public CreateEventStreamingRequest.CreateEventStreamingRequestSinkSinkKafkaParameters setValue(CreateEventStreamingRequest.CreateEventStreamingRequestSinkSinkKafkaParametersValue value)

getValue

public CreateEventStreamingRequest.CreateEventStreamingRequestSinkSinkKafkaParametersValue getValue()