com.opendxl.streaming.client.entity

Class ConsumerRecords.ConsumerRecord

java.lang.Object

com.opendxl.streaming.client.entity.ConsumerRecords.ConsumerRecord

Enclosing class:

ConsumerRecords

public static class ConsumerRecords.ConsumerRecord
extends java.lang.Object

Helper class containing all attributes of a consumed record.

Constructor Summary

Constructors

Constructor and Description
ConsumerRecord()

Method Summary

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.

Methods inherited from class java.lang.Object

equals, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Constructor Detail

ConsumerRecord

public ConsumerRecord()

Method Detail

getRoutingData

public ConsumerRecords.ConsumerRecordRoutingData getRoutingData()

Gets the record routing data

Returns:

a ConsumerRecords.ConsumerRecordRoutingData object containing the record routing data

getMessage

public ConsumerRecords.ConsumerRecordMessage getMessage()

Gets the record message

Returns:

a ConsumerRecords.ConsumerRecordMessage object containing the record message

getPartition

public int getPartition()

Gets the partition from which the record is consumed.

Returns:

number corresponding to the partition from which the record is consumed

getOffset

public long getOffset()

Gets the record offset.

Returns:

number corresponding to the record offset

getTopic

public java.lang.String getTopic()

Gets the topic name from which the record is consumed.

Returns:

record topic name

getShardingKey

public java.lang.String getShardingKey()

Gets the sharding key of the consumed record.

Returns:

sharding key value

getHeaders

public java.util.Map<java.lang.String,java.lang.String> getHeaders()

Gets the record headers.

Returns:

the record headers

getPayload

public java.lang.String getPayload()

Gets the record payload.

Returns:

the record payload

getDecodedPayload

public byte[] getDecodedPayload()

Decodes a Base64 encoded record payload.

Returns:

a Base64 decoded payload