com.opendxl.databus.cli.entity

Class ConsumerRecordResult

java.lang.Object

com.opendxl.databus.cli.entity.ConsumerRecordResult

public class ConsumerRecordResult
extends java.lang.Object

Helper class use to deserialize the Consumer instance

Constructor Summary

Constructors

Constructor and Description
ConsumerRecordResult(java.lang.String shardingKey, java.lang.String payload, java.lang.String composedTopic, java.lang.String topic, java.lang.String tenantGroup, java.util.Map<java.lang.String,java.lang.String> headers, long offset, int partition, long timestamp) Constructor with all parameters

Method Summary

Methods inherited from class java.lang.Object

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

Constructor Detail

ConsumerRecordResult

public ConsumerRecordResult(java.lang.String shardingKey,
                            java.lang.String payload,
                            java.lang.String composedTopic,
                            java.lang.String topic,
                            java.lang.String tenantGroup,
                            java.util.Map<java.lang.String,java.lang.String> headers,
                            long offset,
                            int partition,
                            long timestamp)

Constructor with all parameters

Parameters:

shardingKey - The sharding Key

payload - Message payload

composedTopic - Topic name including the tenant group if apply

topic - Topic name

tenantGroup - Tenant group

headers - Headers

offset - Message offset number

partition - Partition number

timestamp - Message timestamp