com.opendxl.streaming.client.entity

Class ConsumerRecords.ConsumerRecordRoutingData

java.lang.Object

com.opendxl.streaming.client.entity.ConsumerRecords.ConsumerRecordRoutingData

Enclosing class:

ConsumerRecords

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

Topic name and sharding key of the consumed record.

Constructor Summary

Constructors

Constructor and Description
ConsumerRecordRoutingData()

Method Summary

Modifier and Type	Method and Description
java.lang.String	getShardingKey() Gets the record sharding key.
java.lang.String	getTopic() Gets the record topic.

Methods inherited from class java.lang.Object

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

Constructor Detail

ConsumerRecordRoutingData

public ConsumerRecordRoutingData()

Method Detail

getTopic

public java.lang.String getTopic()

Gets the record topic.

Returns:

the record topic name

getShardingKey

public java.lang.String getShardingKey()

Gets the record sharding key.

Returns:

the record sharding key