public static class ConsumerRecords.ConsumerRecord
extends java.lang.Object
Helper class containing all attributes of a consumed record.
| Constructor and Description |
|---|
ConsumerRecord() |
| Modifier and Type | Method and Description |
|---|---|
byte[] |
getDecodedPayload()
Decodes a Base64 encoded record payload.
|
java.util.Map<java.lang.String,java.lang.String> |
getHeaders()
Gets the record headers.
|
ConsumerRecords.ConsumerRecordMessage |
getMessage()
Gets the record message
|
long |
getOffset()
Gets the record offset.
|
int |
getPartition()
Gets the partition from which the record is consumed.
|
java.lang.String |
getPayload()
Gets the record payload.
|
ConsumerRecords.ConsumerRecordRoutingData |
getRoutingData()
Gets the record routing data
|
java.lang.String |
getShardingKey()
Gets the sharding key of the consumed record.
|
java.lang.String |
getTopic()
Gets the topic name from which the record is consumed.
|
public ConsumerRecords.ConsumerRecordRoutingData getRoutingData()
ConsumerRecords.ConsumerRecordRoutingData object containing the record routing datapublic ConsumerRecords.ConsumerRecordMessage getMessage()
ConsumerRecords.ConsumerRecordMessage object containing the record messagepublic int getPartition()
public long getOffset()
public java.lang.String getTopic()
public java.lang.String getShardingKey()
public java.util.Map<java.lang.String,java.lang.String> getHeaders()
public java.lang.String getPayload()
public byte[] getDecodedPayload()