public static class UpdateEventStreamingRequest.UpdateEventStreamingRequestSinkSinkRocketMQCheckpointParameters
extends com.aliyun.tea.TeaModel
| 限定符和类型 | 字段和说明 |
|---|---|
UpdateEventStreamingRequest.UpdateEventStreamingRequestSinkSinkRocketMQCheckpointParametersConsumeTimestamp |
consumeTimestamp
The timestamp that specifies the time from which messages are consumed.
|
UpdateEventStreamingRequest.UpdateEventStreamingRequestSinkSinkRocketMQCheckpointParametersGroup |
group
The ID of the consumer group.
|
String |
instanceId
The ID of the ApsaraMQ for RocketMQ instance.
|
String |
instanceType
The instance type.
|
UpdateEventStreamingRequest.UpdateEventStreamingRequestSinkSinkRocketMQCheckpointParametersTopic |
topic
The name of the topic on the ApsaraMQ for RocketMQ instance.
|
| 构造器和说明 |
|---|
UpdateEventStreamingRequestSinkSinkRocketMQCheckpointParameters() |
@NameInMap(value="ConsumeTimestamp") public UpdateEventStreamingRequest.UpdateEventStreamingRequestSinkSinkRocketMQCheckpointParametersConsumeTimestamp consumeTimestamp
The timestamp that specifies the time from which messages are consumed.
@NameInMap(value="Group") public UpdateEventStreamingRequest.UpdateEventStreamingRequestSinkSinkRocketMQCheckpointParametersGroup group
The ID of the consumer group.
@NameInMap(value="InstanceId") public String instanceId
The ID of the ApsaraMQ for RocketMQ instance.
example:MQ_INST_164901546557****_BAAN****
@NameInMap(value="InstanceType") public String instanceType
The instance type. Valid values:
Cloud_4
@NameInMap(value="Topic") public UpdateEventStreamingRequest.UpdateEventStreamingRequestSinkSinkRocketMQCheckpointParametersTopic topic
The name of the topic on the ApsaraMQ for RocketMQ instance.
public UpdateEventStreamingRequestSinkSinkRocketMQCheckpointParameters()
public static UpdateEventStreamingRequest.UpdateEventStreamingRequestSinkSinkRocketMQCheckpointParameters build(Map<String,?> map) throws Exception
Exceptionpublic UpdateEventStreamingRequest.UpdateEventStreamingRequestSinkSinkRocketMQCheckpointParameters setConsumeTimestamp(UpdateEventStreamingRequest.UpdateEventStreamingRequestSinkSinkRocketMQCheckpointParametersConsumeTimestamp consumeTimestamp)
public UpdateEventStreamingRequest.UpdateEventStreamingRequestSinkSinkRocketMQCheckpointParametersConsumeTimestamp getConsumeTimestamp()
public UpdateEventStreamingRequest.UpdateEventStreamingRequestSinkSinkRocketMQCheckpointParameters setGroup(UpdateEventStreamingRequest.UpdateEventStreamingRequestSinkSinkRocketMQCheckpointParametersGroup group)
public UpdateEventStreamingRequest.UpdateEventStreamingRequestSinkSinkRocketMQCheckpointParametersGroup getGroup()
public UpdateEventStreamingRequest.UpdateEventStreamingRequestSinkSinkRocketMQCheckpointParameters setInstanceId(String instanceId)
public String getInstanceId()
public UpdateEventStreamingRequest.UpdateEventStreamingRequestSinkSinkRocketMQCheckpointParameters setInstanceType(String instanceType)
public String getInstanceType()
public UpdateEventStreamingRequest.UpdateEventStreamingRequestSinkSinkRocketMQCheckpointParameters setTopic(UpdateEventStreamingRequest.UpdateEventStreamingRequestSinkSinkRocketMQCheckpointParametersTopic topic)
public UpdateEventStreamingRequest.UpdateEventStreamingRequestSinkSinkRocketMQCheckpointParametersTopic getTopic()
Copyright © 2026. All rights reserved.