com.taobao.metamorphosis.network
类 OffsetCommand
java.lang.Object
com.taobao.metamorphosis.network.AbstractRequestCommand
com.taobao.metamorphosis.network.OffsetCommand
- 所有已实现的接口:
- com.taobao.gecko.core.command.Command, com.taobao.gecko.core.command.CommandHeader, com.taobao.gecko.core.command.RequestCommand, MetaEncodeCommand
public class OffsetCommand
- extends AbstractRequestCommand
查询最近有效的offset 格式: offset topic group partition offset opaque\r\n
- 作者:
- boyan
从接口 com.taobao.metamorphosis.network.MetaEncodeCommand 继承的字段 |
CRLF, GET_CMD, OFFSET_CMD, PUT_CMD, QUIT_CMD, RESULT_CMD, SPACE, STATS_CMD, SYNC_CMD, TRANS_CMD, VALUE_CMD, VERSION_CMD |
OffsetCommand
public OffsetCommand(String topic,
String group,
int partition,
long offset,
Integer opaque)
getPartition
public int getPartition()
getGroup
public String getGroup()
getOffset
public long getOffset()
hashCode
public int hashCode()
- 覆盖:
- 类
AbstractRequestCommand
中的 hashCode
equals
public boolean equals(Object obj)
- 覆盖:
- 类
AbstractRequestCommand
中的 equals
encode
public com.taobao.gecko.core.buffer.IoBuffer encode()
- 从接口
MetaEncodeCommand
复制的描述
- 编码协议
- 返回:
- 编码后的buffer
Copyright © 2010–2013. All rights reserved.