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 String
KEY_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 long
getCreateTime()
long
getOffset()
int
getPartition()
Map<String,String>
getProps()
String
getTopic()
String
toString()
-
-
-
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:
getTopic
in interfaceorg.apache.sling.distribution.journal.MessageInfo
-
getPartition
public int getPartition()
- Specified by:
getPartition
in interfaceorg.apache.sling.distribution.journal.MessageInfo
-
getOffset
public long getOffset()
- Specified by:
getOffset
in interfaceorg.apache.sling.distribution.journal.MessageInfo
-
getCreateTime
public long getCreateTime()
- Specified by:
getCreateTime
in interfaceorg.apache.sling.distribution.journal.MessageInfo
-
getProps
public Map<String,String> getProps()
- Specified by:
getProps
in interfaceorg.apache.sling.distribution.journal.MessageInfo
-
-