cn.com.antcloud.api.sofakafka.v1_0_0.model

类 PartitionConsumedDTO

java.lang.Object

cn.com.antcloud.api.sofakafka.v1_0_0.model.PartitionConsumedDTO

public class PartitionConsumedDTO
extends Object

分组订阅关系和消费者状态的分区消费详情

构造器概要

构造器

构造器和说明
PartitionConsumedDTO()

方法概要

限定符和类型	方法和说明
Long	getCommitOffset() 提交的offset
String	getGroupId() group id
Long	getMaxOffset() 最大的offset
Long	getPartition() 分区
String	getTopic() topic
Long	getUnconsumed() 未消费的消息数
void	setCommitOffset(Long commitOffset) 提交的offset
void	setGroupId(String groupId) group id
void	setMaxOffset(Long maxOffset) 最大的offset
void	setPartition(Long partition) 分区
void	setTopic(String topic) topic
void	setUnconsumed(Long unconsumed) 未消费的消息数

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

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

构造器详细资料

PartitionConsumedDTO

public PartitionConsumedDTO()

方法详细资料

getTopic

public String getTopic()

topic

setTopic

public void setTopic(String topic)

topic

getGroupId

public String getGroupId()

group id

setGroupId

public void setGroupId(String groupId)

group id

getPartition

public Long getPartition()

分区

setPartition

public void setPartition(Long partition)

分区

getCommitOffset

public Long getCommitOffset()

提交的offset

setCommitOffset

public void setCommitOffset(Long commitOffset)

提交的offset

getMaxOffset

public Long getMaxOffset()

最大的offset

setMaxOffset

public void setMaxOffset(Long maxOffset)

最大的offset

getUnconsumed

public Long getUnconsumed()

未消费的消息数

setUnconsumed

public void setUnconsumed(Long unconsumed)

未消费的消息数