Package org.springframework.kafka.listener.adapter

Class ConsumerRecordMetadata

java.lang.Object
org.springframework.kafka.listener.adapter.ConsumerRecordMetadata
public class ConsumerRecordMetadata extends Object
Used to provide a listener method argument when the user supplies such a parameter. Delegates to RecordMetadata (which is final, hence no subclass) for all except timestamp type.
Since:
2.5
Author:
Gary Russell

  • Constructor Details

    • ConsumerRecordMetadata

      public ConsumerRecordMetadata(org.apache.kafka.clients.producer.RecordMetadata delegate, org.apache.kafka.common.record.TimestampType timestampType)

  • Method Details

    • hasOffset

      public boolean hasOffset()

    • offset

      public long offset()

    • hasTimestamp

      public boolean hasTimestamp()

    • timestamp

      public long timestamp()

    • serializedKeySize

      public int serializedKeySize()

    • serializedValueSize

      public int serializedValueSize()

    • topic

      public String topic()

    • partition

      public int partition()

    • timestampType

      public org.apache.kafka.common.record.TimestampType timestampType()

    • hashCode

      public int hashCode()
      Overrides:
      hashCode in class Object

    • equals

      public boolean equals(Object obj)
      Overrides:
      equals in class Object

    • toString

      public String toString()
      Overrides:
      toString in class Object