public class RedeliverProduceRecord extends DmsProduceRecord
构造器和说明 |
---|
RedeliverProduceRecord() |
限定符和类型 | 方法和说明 |
---|---|
static RedeliverProduceRecord |
convert(DmsProduceRecord dmsProduceRecord)
DmsProduceRecord 转 RedeliverProduceRecord
|
DmsConsumeMessage |
convertToDmsConsumeMessage()
转换为 DmsConsumeMessage 类型
|
java.lang.String |
getKey() |
java.lang.Integer |
getPartition() |
getAttributes, getBody, getRedeliverTimes, getTags, getTimestamp, setAttributes, setBody, setKey, setPartition, setRedeliverTimes, setTags, setTimestamp
public static RedeliverProduceRecord convert(DmsProduceRecord dmsProduceRecord)
dmsProduceRecord
- DmsProduceRecordpublic DmsConsumeMessage convertToDmsConsumeMessage()
public java.lang.Integer getPartition()
getPartition
在类中 DmsProduceRecord
public java.lang.String getKey()
getKey
在类中 DmsProduceRecord