P
- Payload's typepublic class ConsumerRecord<P>
extends java.lang.Object
DatabusConsumer
when a new incoming message comes up.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
|
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
|
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)
key
- sharding keyheaders
- headersmessagePayload
- messagePayloadtopic
- topictenantGroup
- tenant grouppartition
- paritionoffset
- offsettimestamp
- timestamppublic java.lang.String getComposedTopic()
public java.lang.String getTopic()
public java.lang.String getTenantGroup()
public java.lang.String getKey()
public Headers getHeaders()
public MessagePayload<P> getMessagePayload()
public long getOffset()
public int getPartition()
public long getTimestamp()