org.springframework.kafka.listener.adapter

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 to RecordMetadata (which is final, hence no subclass) for all except timestamp type.

Since:

2.5

Author:

Gary Russell

Constructor Summary

Constructors

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

Method Summary

Modifier and Type	Method and 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()

Methods inherited from class java.lang.Object

clone, finalize, getClass, notify, notifyAll, wait, wait, wait

Constructor Detail

ConsumerRecordMetadata

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

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 class java.lang.Object

equals

public boolean equals(java.lang.Object obj)

Overrides:

equals in class java.lang.Object

toString

public java.lang.String toString()

Overrides:

toString in class java.lang.Object