Class ConsumerRecordMetadata
- java.lang.Object
-
- org.springframework.kafka.listener.adapter.ConsumerRecordMetadata
-
public class ConsumerRecordMetadata extends java.lang.Object
Used to provide a listener method argument when the user supplies such a parameter. Delegates toRecordMetadata
(which is final, hence no subclass) for all except timestamp type.- Since:
- 2.5
- Author:
- Gary Russell
-
-
Constructor Summary
Constructors Constructor Description ConsumerRecordMetadata(org.apache.kafka.clients.producer.RecordMetadata delegate, org.apache.kafka.common.record.TimestampType timestampType)
-
Method Summary
All Methods Instance Methods Concrete Methods Modifier and Type Method Description boolean
equals(java.lang.Object obj)
int
hashCode()
boolean
hasOffset()
boolean
hasTimestamp()
long
offset()
int
partition()
int
serializedKeySize()
int
serializedValueSize()
long
timestamp()
org.apache.kafka.common.record.TimestampType
timestampType()
java.lang.String
topic()
java.lang.String
toString()
-
-
-
Method Detail
-
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 java.lang.String topic()
-
partition
public int partition()
-
timestampType
public org.apache.kafka.common.record.TimestampType timestampType()
-
hashCode
public int hashCode()
- Overrides:
hashCode
in classjava.lang.Object
-
equals
public boolean equals(java.lang.Object obj)
- Overrides:
equals
in classjava.lang.Object
-
toString
public java.lang.String toString()
- Overrides:
toString
in classjava.lang.Object
-
-