Class StampedRecord

  • All Implemented Interfaces:
    java.lang.Comparable

    public class StampedRecord
    extends Stamped<org.apache.kafka.clients.consumer.ConsumerRecord<java.lang.Object,​java.lang.Object>>
    • Constructor Summary

      Constructors 
      Constructor Description
      StampedRecord​(org.apache.kafka.clients.consumer.ConsumerRecord<java.lang.Object,​java.lang.Object> record, long timestamp)  
    • Constructor Detail

      • StampedRecord

        public StampedRecord​(org.apache.kafka.clients.consumer.ConsumerRecord<java.lang.Object,​java.lang.Object> record,
                             long timestamp)
    • Method Detail

      • topic

        public java.lang.String topic()
      • partition

        public int partition()
      • key

        public java.lang.Object key()
      • value

        public java.lang.Object value()
      • offset

        public long offset()
      • headers

        public org.apache.kafka.common.header.Headers headers()
      • toString

        public java.lang.String toString()
        Overrides:
        toString in class java.lang.Object