cn.com.antcloud.api.sofakafka.v1_0_0.request

类 UpdateGroupOffsetRequest

java.lang.Object

cn.com.antcloud.api.common.BaseRequest<T>

cn.com.antcloud.api.product.AntCloudProdRequest<UpdateGroupOffsetResponse>

cn.com.antcloud.api.sofakafka.v1_0_0.request.UpdateGroupOffsetRequest

public class UpdateGroupOffsetRequest
extends cn.com.antcloud.api.product.AntCloudProdRequest<UpdateGroupOffsetResponse>

修改group所消费的topic-partition的offset

构造器概要

构造器

构造器和说明
UpdateGroupOffsetRequest()
UpdateGroupOffsetRequest(String productInstanceId)

方法概要

限定符和类型	方法和说明
Boolean	getBegging() true表示最开始，false表示最新
String	getCell() cell
String	getGroupId() group id
String	getInstanceId() instance id
Long	getOffset() type=1表示将offset重置的位置 type=2表示向前或向后移动的位置，负数表示向前，正数表示向后
String	getPartitions() partition列表 用,隔开
Long	getTime() 按时间重置的时间戳
String	getTopic() topic
Long	getType() 1.将offset设置到指定位置。
void	setBegging(Boolean begging) true表示最开始，false表示最新
void	setCell(String cell) cell
void	setGroupId(String groupId) group id
void	setInstanceId(String instanceId) instance id
void	setOffset(Long offset) type=1表示将offset重置的位置 type=2表示向前或向后移动的位置，负数表示向前，正数表示向后
void	setPartitions(String partitions) partition列表 用,隔开
void	setTime(Long time) 按时间重置的时间戳
void	setTopic(String topic) topic
void	setType(Long type) 1.将offset设置到指定位置。

从类继承的方法 cn.com.antcloud.api.product.AntCloudProdRequest

getProductInstanceId, getRegionName, setProductInstanceId, setRegionName

从类继承的方法 cn.com.antcloud.api.common.BaseRequest

getAuthToken, getMethod, getReqBizId, getReqMsgId, getSdkVersion, getSignType, getVersion, responseClass, setAuthToken, setMethod, setReqBizId, setReqMsgId, setSdkVersion, setSignType, setVersion

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

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

构造器详细资料

UpdateGroupOffsetRequest

public UpdateGroupOffsetRequest(String productInstanceId)

UpdateGroupOffsetRequest

public UpdateGroupOffsetRequest()

方法详细资料

getInstanceId

public String getInstanceId()

instance id

setInstanceId

public void setInstanceId(String instanceId)

instance id

getCell

public String getCell()

cell

setCell

public void setCell(String cell)

cell

getGroupId

public String getGroupId()

group id

setGroupId

public void setGroupId(String groupId)

group id

getTopic

public String getTopic()

topic

setTopic

public void setTopic(String topic)

topic

getPartitions

public String getPartitions()

partition列表 用,隔开

setPartitions

public void setPartitions(String partitions)

partition列表 用,隔开

getType

public Long getType()

1.将offset设置到指定位置。 2.将offset向前或向后移动指定位置。 3.从最新/最开始位置开始消费。 4.按时间位进行消费位点重置。

setType

public void setType(Long type)

1.将offset设置到指定位置。 2.将offset向前或向后移动指定位置。 3.从最新/最开始位置开始消费。 4.按时间位进行消费位点重置。

getOffset

public Long getOffset()

type=1表示将offset重置的位置 type=2表示向前或向后移动的位置，负数表示向前，正数表示向后

setOffset

public void setOffset(Long offset)

type=1表示将offset重置的位置 type=2表示向前或向后移动的位置，负数表示向前，正数表示向后

getBegging

public Boolean getBegging()

true表示最开始，false表示最新

setBegging

public void setBegging(Boolean begging)

true表示最开始，false表示最新

getTime

public Long getTime()

按时间重置的时间戳

setTime

public void setTime(Long time)

按时间重置的时间戳