public class StampedRecord extends Stamped<org.apache.kafka.clients.consumer.ConsumerRecord<java.lang.Object,java.lang.Object>>
Constructor and Description |
---|
StampedRecord(org.apache.kafka.clients.consumer.ConsumerRecord<java.lang.Object,java.lang.Object> record,
long timestamp) |
Modifier and Type | Method and Description |
---|---|
org.apache.kafka.common.header.Headers |
headers() |
java.lang.Object |
key() |
long |
offset() |
int |
partition() |
java.lang.String |
topic() |
java.lang.String |
toString() |
java.lang.Object |
value() |
public StampedRecord(org.apache.kafka.clients.consumer.ConsumerRecord<java.lang.Object,java.lang.Object> record, long timestamp)
public java.lang.String topic()
public int partition()
public java.lang.Object key()
public java.lang.Object value()
public long offset()
public org.apache.kafka.common.header.Headers headers()
public java.lang.String toString()
toString
in class java.lang.Object