com.opendxl.streaming.client.entity

Class ConsumerRecords

java.lang.Object

com.opendxl.streaming.client.entity.ConsumerRecords

public class ConsumerRecords
extends java.lang.Object

Helper class use to deserialize the ConsumerService responses of consume() requests.

It consists of a list of ConsumerRecords.ConsumerRecord objects

Nested Class Summary

Nested Classes

Modifier and Type	Class and Description
static class	ConsumerRecords.ConsumerRecord Helper class containing all attributes of a consumed record.
static class	ConsumerRecords.ConsumerRecordMessage Headers and payload of the consumed record.
static class	ConsumerRecords.ConsumerRecordRoutingData Topic name and sharding key of the consumed record.

Constructor Summary

Constructors

Constructor and Description
ConsumerRecords()

Method Summary

Modifier and Type	Method and Description
java.util.List<ConsumerRecords.ConsumerRecord>	getRecords()

Methods inherited from class java.lang.Object

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

Constructor Detail

ConsumerRecords

public ConsumerRecords()

Method Detail

getRecords

public java.util.List<ConsumerRecords.ConsumerRecord> getRecords()