Class KafkaMessageInfo
- java.lang.Object
-
- org.apache.sling.distribution.journal.kafka.KafkaMessageInfo
-
- All Implemented Interfaces:
org.apache.sling.distribution.journal.MessageInfo
public class KafkaMessageInfo extends Object implements org.apache.sling.distribution.journal.MessageInfo
-
-
Field Summary
Fields Modifier and Type Field Description static StringKEY_MESSAGE_TYPE
-
Constructor Summary
Constructors Constructor Description KafkaMessageInfo(org.apache.kafka.clients.consumer.ConsumerRecord<String,?> record)KafkaMessageInfo(org.apache.kafka.clients.consumer.ConsumerRecord<String,?> record, Map<String,String> props)
-
Method Summary
All Methods Instance Methods Concrete Methods Modifier and Type Method Description longgetCreateTime()longgetOffset()intgetPartition()Map<String,String>getProps()StringgetTopic()StringtoString()
-
-
-
Field Detail
-
KEY_MESSAGE_TYPE
public static final String KEY_MESSAGE_TYPE
- See Also:
- Constant Field Values
-
-
Method Detail
-
getTopic
public String getTopic()
- Specified by:
getTopicin interfaceorg.apache.sling.distribution.journal.MessageInfo
-
getPartition
public int getPartition()
- Specified by:
getPartitionin interfaceorg.apache.sling.distribution.journal.MessageInfo
-
getOffset
public long getOffset()
- Specified by:
getOffsetin interfaceorg.apache.sling.distribution.journal.MessageInfo
-
getCreateTime
public long getCreateTime()
- Specified by:
getCreateTimein interfaceorg.apache.sling.distribution.journal.MessageInfo
-
getProps
public Map<String,String> getProps()
- Specified by:
getPropsin interfaceorg.apache.sling.distribution.journal.MessageInfo
-
-