com.opendxl.databus.consumer

Class ConsumerRecord<P>

java.lang.Object

com.opendxl.databus.consumer.ConsumerRecord<P>

Type Parameters:

P - Payload's type

public class ConsumerRecord<P>
extends java.lang.Object

It represents a consumer record created by a DatabusConsumer when a new incoming message comes up.

Constructor Summary

Constructors

Constructor and Description
ConsumerRecord(java.lang.String key, Headers headers, MessagePayload<P> messagePayload, java.lang.String topic, java.lang.String tenantGroup, java.lang.Integer partition, long offset, long timestamp) Construct a record received from a specified topic and partition

Method Summary

Modifier and Type	Method and Description
java.lang.String	getComposedTopic() The Composed Topic name
Headers	getHeaders() The Headers
java.lang.String	getKey() The Key
MessagePayload<P>	getMessagePayload() The message payload
long	getOffset() The Offset number
int	getPartition() The Partition number
java.lang.String	getTenantGroup() The Tenant Group
long	getTimestamp() The Timestamp as Long
java.lang.String	getTopic() The Topic name

Methods inherited from class java.lang.Object

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

Constructor Detail

ConsumerRecord

public ConsumerRecord(java.lang.String key,
                      Headers headers,
                      MessagePayload<P> messagePayload,
                      java.lang.String topic,
                      java.lang.String tenantGroup,
                      java.lang.Integer partition,
                      long offset,
                      long timestamp)

Construct a record received from a specified topic and partition

Parameters:

key - sharding key

headers - headers

messagePayload - messagePayload

topic - topic

tenantGroup - tenant group

partition - parition

offset - offset

timestamp - timestamp

Method Detail

getComposedTopic

public java.lang.String getComposedTopic()

The Composed Topic name

Returns:

The Composed Topic name which includes the String sum of topic name with the tenant group.

getTopic

public java.lang.String getTopic()

The Topic name

Returns:

Topic name as String.

getTenantGroup

public java.lang.String getTenantGroup()

The Tenant Group

Returns:

Tenant Group as String.

getKey

public java.lang.String getKey()

The Key

Returns:

The Key as String.

getHeaders

public Headers getHeaders()

The Headers

Returns:

The Headers.

getMessagePayload

public MessagePayload<P> getMessagePayload()

The message payload

Returns:

A MessagePayload instance

getOffset

public long getOffset()

The Offset number

Returns:

Offset

getPartition

public int getPartition()

The Partition number

Returns:

The partition number

getTimestamp

public long getTimestamp()

The Timestamp as Long

Returns:

Timestamp when the consumer record was created