Class KafkaMessageInfo

  • All Implemented Interfaces:
    org.apache.sling.distribution.journal.MessageInfo

    public class KafkaMessageInfo
    extends Object
    implements org.apache.sling.distribution.journal.MessageInfo
    • Constructor Detail

      • KafkaMessageInfo

        public KafkaMessageInfo​(org.apache.kafka.clients.consumer.ConsumerRecord<String,​?> record)
      • KafkaMessageInfo

        public KafkaMessageInfo​(org.apache.kafka.clients.consumer.ConsumerRecord<String,​?> record,
                                Map<String,​String> props)
    • Method Detail

      • getTopic

        public String getTopic()
        Specified by:
        getTopic in interface org.apache.sling.distribution.journal.MessageInfo
      • getPartition

        public int getPartition()
        Specified by:
        getPartition in interface org.apache.sling.distribution.journal.MessageInfo
      • getOffset

        public long getOffset()
        Specified by:
        getOffset in interface org.apache.sling.distribution.journal.MessageInfo
      • getCreateTime

        public long getCreateTime()
        Specified by:
        getCreateTime in interface org.apache.sling.distribution.journal.MessageInfo
      • getProps

        public Map<String,​String> getProps()
        Specified by:
        getProps in interface org.apache.sling.distribution.journal.MessageInfo