com.aliyun.eventbridge20200401.models

类 UpdateEventStreamingRequest.UpdateEventStreamingRequestSinkSinkKafkaParameters

java.lang.Object

com.aliyun.tea.TeaModel

com.aliyun.eventbridge20200401.models.UpdateEventStreamingRequest.UpdateEventStreamingRequestSinkSinkKafkaParameters

封闭类:

UpdateEventStreamingRequest

public static class UpdateEventStreamingRequest.UpdateEventStreamingRequestSinkSinkKafkaParameters
extends com.aliyun.tea.TeaModel

字段概要

字段

限定符和类型	字段和说明
UpdateEventStreamingRequest.UpdateEventStreamingRequestSinkSinkKafkaParametersAcks	acks The acknowledgment (ACK) mode.
String	compressionType
UpdateEventStreamingRequest.UpdateEventStreamingRequestSinkSinkKafkaParametersDynamicTopic	dynamicTopic
UpdateEventStreamingRequest.UpdateEventStreamingRequestSinkSinkKafkaParametersHeaders	headers The metadata added to messages in the ApsaraMQ for Kafka instance.
UpdateEventStreamingRequest.UpdateEventStreamingRequestSinkSinkKafkaParametersInstanceId	instanceId The ID of the ApsaraMQ for Kafka instance.
UpdateEventStreamingRequest.UpdateEventStreamingRequestSinkSinkKafkaParametersKey	key The message key.
UpdateEventStreamingRequest.UpdateEventStreamingRequestSinkSinkKafkaParametersTopic	topic The name of the topic on the ApsaraMQ for Kafka instance.
UpdateEventStreamingRequest.UpdateEventStreamingRequestSinkSinkKafkaParametersValue	value The message body.

构造器概要

构造器

构造器和说明
UpdateEventStreamingRequestSinkSinkKafkaParameters()

方法概要

限定符和类型	方法和说明
static UpdateEventStreamingRequest.UpdateEventStreamingRequestSinkSinkKafkaParameters	build(Map<String,?> map)
UpdateEventStreamingRequest.UpdateEventStreamingRequestSinkSinkKafkaParametersAcks	getAcks()
String	getCompressionType()
UpdateEventStreamingRequest.UpdateEventStreamingRequestSinkSinkKafkaParametersDynamicTopic	getDynamicTopic()
UpdateEventStreamingRequest.UpdateEventStreamingRequestSinkSinkKafkaParametersHeaders	getHeaders()
UpdateEventStreamingRequest.UpdateEventStreamingRequestSinkSinkKafkaParametersInstanceId	getInstanceId()
UpdateEventStreamingRequest.UpdateEventStreamingRequestSinkSinkKafkaParametersKey	getKey()
UpdateEventStreamingRequest.UpdateEventStreamingRequestSinkSinkKafkaParametersTopic	getTopic()
UpdateEventStreamingRequest.UpdateEventStreamingRequestSinkSinkKafkaParametersValue	getValue()
UpdateEventStreamingRequest.UpdateEventStreamingRequestSinkSinkKafkaParameters	setAcks(UpdateEventStreamingRequest.UpdateEventStreamingRequestSinkSinkKafkaParametersAcks acks)
UpdateEventStreamingRequest.UpdateEventStreamingRequestSinkSinkKafkaParameters	setCompressionType(String compressionType)
UpdateEventStreamingRequest.UpdateEventStreamingRequestSinkSinkKafkaParameters	setDynamicTopic(UpdateEventStreamingRequest.UpdateEventStreamingRequestSinkSinkKafkaParametersDynamicTopic dynamicTopic)
UpdateEventStreamingRequest.UpdateEventStreamingRequestSinkSinkKafkaParameters	setHeaders(UpdateEventStreamingRequest.UpdateEventStreamingRequestSinkSinkKafkaParametersHeaders headers)
UpdateEventStreamingRequest.UpdateEventStreamingRequestSinkSinkKafkaParameters	setInstanceId(UpdateEventStreamingRequest.UpdateEventStreamingRequestSinkSinkKafkaParametersInstanceId instanceId)
UpdateEventStreamingRequest.UpdateEventStreamingRequestSinkSinkKafkaParameters	setKey(UpdateEventStreamingRequest.UpdateEventStreamingRequestSinkSinkKafkaParametersKey key)
UpdateEventStreamingRequest.UpdateEventStreamingRequestSinkSinkKafkaParameters	setTopic(UpdateEventStreamingRequest.UpdateEventStreamingRequestSinkSinkKafkaParametersTopic topic)
UpdateEventStreamingRequest.UpdateEventStreamingRequestSinkSinkKafkaParameters	setValue(UpdateEventStreamingRequest.UpdateEventStreamingRequestSinkSinkKafkaParametersValue 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 UpdateEventStreamingRequest.UpdateEventStreamingRequestSinkSinkKafkaParametersAcks 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 UpdateEventStreamingRequest.UpdateEventStreamingRequestSinkSinkKafkaParametersDynamicTopic dynamicTopic

headers

@NameInMap(value="Headers")
public UpdateEventStreamingRequest.UpdateEventStreamingRequestSinkSinkKafkaParametersHeaders headers

The metadata added to messages in the ApsaraMQ for Kafka instance.

instanceId

@NameInMap(value="InstanceId")
public UpdateEventStreamingRequest.UpdateEventStreamingRequestSinkSinkKafkaParametersInstanceId instanceId

The ID of the ApsaraMQ for Kafka instance.

key

@NameInMap(value="Key")
public UpdateEventStreamingRequest.UpdateEventStreamingRequestSinkSinkKafkaParametersKey key

The message key.

topic

@NameInMap(value="Topic")
public UpdateEventStreamingRequest.UpdateEventStreamingRequestSinkSinkKafkaParametersTopic topic

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

value

@NameInMap(value="Value")
public UpdateEventStreamingRequest.UpdateEventStreamingRequestSinkSinkKafkaParametersValue value

The message body.

构造器详细资料

UpdateEventStreamingRequestSinkSinkKafkaParameters

public UpdateEventStreamingRequestSinkSinkKafkaParameters()

方法详细资料

build

public static UpdateEventStreamingRequest.UpdateEventStreamingRequestSinkSinkKafkaParameters build(Map<String,?> map)
                                                                                            throws Exception

抛出:

Exception

setAcks

public UpdateEventStreamingRequest.UpdateEventStreamingRequestSinkSinkKafkaParameters setAcks(UpdateEventStreamingRequest.UpdateEventStreamingRequestSinkSinkKafkaParametersAcks acks)

getAcks

public UpdateEventStreamingRequest.UpdateEventStreamingRequestSinkSinkKafkaParametersAcks getAcks()

setCompressionType

public UpdateEventStreamingRequest.UpdateEventStreamingRequestSinkSinkKafkaParameters setCompressionType(String compressionType)

getCompressionType

public String getCompressionType()

setDynamicTopic

public UpdateEventStreamingRequest.UpdateEventStreamingRequestSinkSinkKafkaParameters setDynamicTopic(UpdateEventStreamingRequest.UpdateEventStreamingRequestSinkSinkKafkaParametersDynamicTopic dynamicTopic)

getDynamicTopic

public UpdateEventStreamingRequest.UpdateEventStreamingRequestSinkSinkKafkaParametersDynamicTopic getDynamicTopic()

setHeaders

public UpdateEventStreamingRequest.UpdateEventStreamingRequestSinkSinkKafkaParameters setHeaders(UpdateEventStreamingRequest.UpdateEventStreamingRequestSinkSinkKafkaParametersHeaders headers)

getHeaders

public UpdateEventStreamingRequest.UpdateEventStreamingRequestSinkSinkKafkaParametersHeaders getHeaders()

setInstanceId

public UpdateEventStreamingRequest.UpdateEventStreamingRequestSinkSinkKafkaParameters setInstanceId(UpdateEventStreamingRequest.UpdateEventStreamingRequestSinkSinkKafkaParametersInstanceId instanceId)

getInstanceId

public UpdateEventStreamingRequest.UpdateEventStreamingRequestSinkSinkKafkaParametersInstanceId getInstanceId()

setKey

public UpdateEventStreamingRequest.UpdateEventStreamingRequestSinkSinkKafkaParameters setKey(UpdateEventStreamingRequest.UpdateEventStreamingRequestSinkSinkKafkaParametersKey key)

getKey

public UpdateEventStreamingRequest.UpdateEventStreamingRequestSinkSinkKafkaParametersKey getKey()

setTopic

public UpdateEventStreamingRequest.UpdateEventStreamingRequestSinkSinkKafkaParameters setTopic(UpdateEventStreamingRequest.UpdateEventStreamingRequestSinkSinkKafkaParametersTopic topic)

getTopic

public UpdateEventStreamingRequest.UpdateEventStreamingRequestSinkSinkKafkaParametersTopic getTopic()

setValue

public UpdateEventStreamingRequest.UpdateEventStreamingRequestSinkSinkKafkaParameters setValue(UpdateEventStreamingRequest.UpdateEventStreamingRequestSinkSinkKafkaParametersValue value)

getValue

public UpdateEventStreamingRequest.UpdateEventStreamingRequestSinkSinkKafkaParametersValue getValue()